update (#978)

0xPolygonHermez · Aug 19, 2024 · 7a8ab91 · 7a8ab91
1 parent a3a37cc
commit 7a8ab91
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/zk/datastream/server/datastream_populate.go b/zk/datastream/server/datastream_populate.go
@@ -192,6 +192,12 @@ LOOP:
 				return err
 			}
 			entries = make([]DataStreamEntryProto, 0, insertEntryCount)
+			if err = srv.stream.CommitAtomicOp(); err != nil {
+				return err
+			}
+			if err = srv.stream.StartAtomicOp(); err != nil {
+				return err
+			}
 		}
 	}