fix precommit scheduling

eigerco · Feb 18, 2025 · c6c7dea · c6c7dea
1 parent 176455a
commit c6c7dea
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/storage-provider/server/src/pipeline/add_piece.rs b/storage-provider/server/src/pipeline/add_piece.rs
@@ -61,7 +61,11 @@ pub async fn add_piece(
             fill_percentage,
             fill_threshold,
         );
-        return state.send_pre_commit(sector_number);
+
+        // Schedule a new precommit to be executed immediately
+        let when = Duration::from_secs(0);
+        schedule_pre_commit(state.clone(), tracker, sector_number, when).await;
+        return Ok(());
     }
     tracing::debug!(
         %sector_number,
@@ -76,6 +80,7 @@ pub async fn add_piece(
         state.server_info.sealing_configuration.wait_deals_delay,
         duration_to_deal_start,
     );
+
     // We always try to schedule a new pre-commit
     schedule_pre_commit(state.clone(), tracker, sector_number, when).await;