obeli-sk
diff --git a/‎crates/wasm-workers/src/workflow/replay_db_proxy.rs‎
Lines changed: 4 additions & 4 deletions b/‎crates/wasm-workers/src/workflow/replay_db_proxy.rs‎
Lines changed: 4 additions & 4 deletions
@@ -37,15 +37,15 @@ impl ReplayEventCollector {
 pub(crate) async fn apply_writes(
     conn: &dyn DbConnection,
     actual: Vec<CapturedDbWrite>,
-    version: Version,
+    old_version: Version,
 ) -> Result<Version, DbErrorWrite> {
-    let mut new_version = version;
+    let mut version = old_version; // In case `actual` is empty, just return the old version.
     for write in &actual {
         if let Some(v) = apply_captured_write(write, conn).await? {
-            new_version = v;
+            version = v;
         }
     }
-    Ok(new_version)
+    Ok(version)
 }
 
 async fn apply_captured_write(
Original file line number	Diff line number	Diff line change
`@@ -37,15 +37,15 @@ impl ReplayEventCollector {`
`37`	`37`	`pub(crate) async fn apply_writes(`
`38`	`38`	`conn: &dyn DbConnection,`
`39`	`39`	`actual: Vec<CapturedDbWrite>,`
`40`		`- version: Version,`
	`40`	`+ old_version: Version,`
`41`	`41`	`) -> Result<Version, DbErrorWrite> {`
`42`		`- let mut new_version = version;`
	`42`	+ let mut version = old_version; // In case `actual` is empty, just return the old version.
`43`	`43`	`for write in &actual {`
`44`	`44`	`if let Some(v) = apply_captured_write(write, conn).await? {`
`45`		`- new_version = v;`
	`45`	`+ version = v;`
`46`	`46`	`}`
`47`	`47`	`}`
`48`		`- Ok(new_version)`
	`48`	`+ Ok(version)`
`49`	`49`	`}`
`50`	`50`
`51`	`51`	`async fn apply_captured_write(`