Skip to content

Commit da85ad7

Browse files
committed
Cleanup
1 parent c40d5f2 commit da85ad7

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

rust/worker/src/execution/orchestration/compact.rs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -671,7 +671,9 @@ impl Handler<TaskResult<ApplyLogToSegmentWriterOutput, ApplyLogToSegmentWriterOp
671671
self.num_write_tasks -= 1;
672672
if self.num_write_tasks == 0 {
673673
let (record_segment_writer, hnsw_segment_writer, metadata_segment_writer) =
674-
self.get_segment_writers().await.unwrap(); // todo
674+
self.writers
675+
.clone()
676+
.expect("Invariant violation. Writers not set.");
675677

676678
self.flush_s3(
677679
record_segment_writer.clone(),

0 commit comments

Comments
 (0)