docs: Add comment

peasee · peasee · commit a1d8f08051b4 · 2026-02-03T10:14:28.000+10:00
diff --git a/ballista/scheduler/src/scheduler_server/query_stage_scheduler.rs b/ballista/scheduler/src/scheduler_server/query_stage_scheduler.rs
@@ -122,6 +122,8 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan>
                 }
 
                 let state = self.state.clone();
+
+                // Clone the job state sender to move into the async task
                 let job_state_sender = self.job_state_sender.clone();
                 tokio::spawn(async move {
                     let event = if let Err(e) = state

Original file line number	Diff line number	Diff line change
`@@ -122,6 +122,8 @@ impl<T: 'static + AsLogicalPlan, U: 'static + AsExecutionPlan>`
`122`	`122`	`}`
`123`	`123`
`124`	`124`	`let state = self.state.clone();`
	`125`	`+`
	`126`	`+ // Clone the job state sender to move into the async task`
`125`	`127`	`let job_state_sender = self.job_state_sender.clone();`
`126`	`128`	`tokio::spawn(async move {`
`127`	`129`	`let event = if let Err(e) = state`