diff options
Diffstat (limited to 'makima/src/server/handlers/mesh_supervisor.rs')
| -rw-r--r-- | makima/src/server/handlers/mesh_supervisor.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/makima/src/server/handlers/mesh_supervisor.rs b/makima/src/server/handlers/mesh_supervisor.rs index 8bf2534..c9cb849 100644 --- a/makima/src/server/handlers/mesh_supervisor.rs +++ b/makima/src/server/handlers/mesh_supervisor.rs @@ -410,6 +410,7 @@ pub async fn try_start_pending_task( auto_merge_local: contract.auto_merge_local, // For retried tasks, use their own worktree (they already have state from previous attempt) supervisor_worktree_task_id: None, + directive_id: updated_task.directive_id, }; if let Err(e) = state.send_daemon_command(daemon.id, cmd).await { @@ -732,6 +733,7 @@ pub async fn spawn_task( auto_merge_local: contract.auto_merge_local, // All tasks share the supervisor's worktree supervisor_worktree_task_id: Some(supervisor_id), + directive_id: updated_task.directive_id, }; if let Err(e) = state.send_daemon_command(daemon.id, cmd).await { @@ -2239,6 +2241,7 @@ pub async fn resume_supervisor( local_only: contract.local_only, auto_merge_local: contract.auto_merge_local, supervisor_worktree_task_id: None, // Supervisor uses its own worktree + directive_id: supervisor_task.directive_id, }; if let Err(e) = state.send_daemon_command(target_daemon_id, command).await { |