refactor: add 'start_time' in CompactionJob

zyy17 · Jun 22, 2024 · 840e642 · 840e642
1 parent d08b56e
commit 840e642
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/src/mito2/src/compaction.rs b/src/mito2/src/compaction.rs
@@ -287,6 +287,7 @@ impl CompactionScheduler {
                 let remote_compaction_job = CompactionJob {
                     compaction_region: compaction_region.clone(),
                     picker_output: picker_output.clone(),
+                    start_time,
                 };
 
                 let result = remote_job_scheduler

diff --git a/src/mito2/src/schedule/remote_job_scheduler.rs b/src/mito2/src/schedule/remote_job_scheduler.rs
@@ -70,6 +70,7 @@ pub enum RemoteJob {
 pub struct CompactionJob {
     pub compaction_region: CompactionRegion,
     pub picker_output: PickerOutput,
+    pub start_time: Instant,
 }
 
 /// RemoteJobResult is the result of a remote job.