diff --git a/crates/sui-data-ingestion-core/src/worker_pool.rs b/crates/sui-data-ingestion-core/src/worker_pool.rs
index 1bdc0e8a44626..75ab9c991f6e0 100644
--- a/crates/sui-data-ingestion-core/src/worker_pool.rs
+++ b/crates/sui-data-ingestion-core/src/worker_pool.rs
@@ -123,7 +123,11 @@ impl<W: Worker + 'static> WorkerPool<W> {
                         }
                     }
                 }
-                Some(checkpoint) = checkpoint_receiver.recv() => {
+                maybe_checkpoint = checkpoint_receiver.recv() => {
+                    if maybe_checkpoint.is_none() {
+                        break;
+                    }
+                    let checkpoint = maybe_checkpoint.expect("invariant's checked");
                     let sequence_number = checkpoint.checkpoint_summary.sequence_number;
                     if sequence_number < current_checkpoint_number {
                         continue;