From d16523755693617b6f906a82f16408be32da9679 Mon Sep 17 00:00:00 2001
From: Max Isom <hi@maxisom.me>
Date: Mon, 6 Jan 2025 12:39:30 -0800
Subject: [PATCH] Address PR comment

---
 rust/worker/src/execution/orchestration/compact.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/rust/worker/src/execution/orchestration/compact.rs b/rust/worker/src/execution/orchestration/compact.rs
index cb5c6d98517..7cc4b783ccc 100644
--- a/rust/worker/src/execution/orchestration/compact.rs
+++ b/rust/worker/src/execution/orchestration/compact.rs
@@ -874,7 +874,7 @@ impl Handler<TaskResult<FlushSegmentWriterOutput, FlushSegmentWriterOperatorErro
 
         if self.num_uncompleted_tasks_by_segment.is_empty() {
             // Unwrap should be safe here as we are guaranteed to have a value by construction
-            self.register(self.pulled_log_offset.unwrap(), ctx).await;
+            self.register(self.pulled_log_offset.expect("Invariant violation: pulled_log_offset should have been populated at this point."), ctx).await;
         }
     }
 }