fix CRDTs using old transaction

sourcenetwork · Jun 3, 2024 · 14c5967 · 14c5967
1 parent c8eaedd
commit 14c5967
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/db/merge.go b/internal/db/merge.go
@@ -119,6 +119,8 @@ func (db *db) executeMerge(ctx context.Context, dagMerge events.DAGMerge) error
 				ctx = SetContextTxn(ctx, txn)
 				mp.txn = txn
 				mp.ls.SetReadStorage(txn.DAGstore().AsIPLDStorage())
+				// Reset the CRDTs to avoid reusing the old transaction.
+				mp.mCRDTs = make(map[string]merklecrdt.MerkleCRDT)
 				continue
 			}
 			return err