diff --git a/src/mito2/src/worker/handle_write.rs b/src/mito2/src/worker/handle_write.rs index f1ac4af11a..7a012b0325 100644 --- a/src/mito2/src/worker/handle_write.rs +++ b/src/mito2/src/worker/handle_write.rs @@ -73,6 +73,7 @@ impl RegionWorkerLoop { region_ctx.set_error(e); } } + match wal_writer.write_to_wal().await.map_err(Arc::new) { Ok(response) => { update_next_entry_ids(&mut region_ctxs, &response);