summaryrefslogtreecommitdiff
path: root/makima/src/server/handlers/mesh.rs
diff options
context:
space:
mode:
authorsoryu <soryu@soryu.co>2026-02-09 15:55:01 +0000
committersoryu <soryu@soryu.co>2026-02-09 15:55:01 +0000
commit339c1769379a851c4126021132573bd4b7994cf2 (patch)
tree8a9a3cdc9d86b3dc2e6883853fb7b22c21dd9e99 /makima/src/server/handlers/mesh.rs
parentbfa7bd8d7609397f570f1cd9b83d2269abc0ed63 (diff)
downloadsoryu-339c1769379a851c4126021132573bd4b7994cf2.tar.gz
soryu-339c1769379a851c4126021132573bd4b7994cf2.zip
Set directive env vars correctly for daemon
Diffstat (limited to 'makima/src/server/handlers/mesh.rs')
-rw-r--r--makima/src/server/handlers/mesh.rs6
1 files changed, 6 insertions, 0 deletions
diff --git a/makima/src/server/handlers/mesh.rs b/makima/src/server/handlers/mesh.rs
index 5572d95..eb87e17 100644
--- a/makima/src/server/handlers/mesh.rs
+++ b/makima/src/server/handlers/mesh.rs
@@ -709,6 +709,7 @@ pub async fn start_task(
local_only,
auto_merge_local,
supervisor_worktree_task_id: None, // Not spawned by supervisor
+ directive_id: task.directive_id,
};
tracing::info!(
@@ -764,6 +765,7 @@ pub async fn start_task(
local_only,
auto_merge_local,
supervisor_worktree_task_id: None, // Not spawned by supervisor
+ directive_id: task.directive_id,
};
if state.send_daemon_command(alt_daemon_id, alt_command).await.is_ok() {
@@ -1181,6 +1183,7 @@ pub async fn send_message(
local_only,
auto_merge_local,
supervisor_worktree_task_id: None, // Not spawned by supervisor
+ directive_id: updated_task.directive_id,
};
if state.send_daemon_command(new_daemon_id, spawn_cmd).await.is_ok() {
@@ -2825,6 +2828,7 @@ pub async fn reassign_task(
local_only,
auto_merge_local,
supervisor_worktree_task_id: None, // Not spawned by supervisor
+ directive_id: task.directive_id,
};
tracing::info!(
@@ -3165,6 +3169,7 @@ pub async fn continue_task(
local_only,
auto_merge_local,
supervisor_worktree_task_id: None, // Not spawned by supervisor
+ directive_id: task.directive_id,
};
tracing::info!(
@@ -4097,6 +4102,7 @@ pub async fn branch_task(
local_only: false, // No contract, so not local_only
auto_merge_local: false, // No contract, so no auto_merge_local
supervisor_worktree_task_id: None, // Not spawned by supervisor
+ directive_id: None,
};
if let Err(e) = state.send_daemon_command(target_daemon_id, command).await {