summaryrefslogtreecommitdiff
path: root/makima/src/server/handlers/mesh_supervisor.rs
diff options
context:
space:
mode:
authorsoryu <soryu@soryu.co>2026-01-17 05:37:47 +0000
committersoryu <soryu@soryu.co>2026-01-17 05:38:07 +0000
commit2f62df1cc89a23a5bd30e1a3f68a39bcfce9665c (patch)
treec658378488cf6db293f7ca71d3ca957249a6309e /makima/src/server/handlers/mesh_supervisor.rs
parent75d9644d44ba998a32ed14c072e883a75145ab72 (diff)
downloadsoryu-2f62df1cc89a23a5bd30e1a3f68a39bcfce9665c.tar.gz
soryu-2f62df1cc89a23a5bd30e1a3f68a39bcfce9665c.zip
Add heartbeat commits
Diffstat (limited to 'makima/src/server/handlers/mesh_supervisor.rs')
-rw-r--r--makima/src/server/handlers/mesh_supervisor.rs15
1 files changed, 15 insertions, 0 deletions
diff --git a/makima/src/server/handlers/mesh_supervisor.rs b/makima/src/server/handlers/mesh_supervisor.rs
index 754d086..29eef81 100644
--- a/makima/src/server/handlers/mesh_supervisor.rs
+++ b/makima/src/server/handlers/mesh_supervisor.rs
@@ -576,6 +576,21 @@ pub async fn spawn_task(
"Supervisor spawned new task"
);
+ // Record history event for task spawned by supervisor
+ let _ = repository::record_history_event(
+ pool,
+ owner_id,
+ task.contract_id,
+ Some(task.id),
+ "task",
+ Some("spawned"),
+ None,
+ serde_json::json!({
+ "name": &task.name,
+ "spawnedBy": supervisor_id.to_string(),
+ }),
+ ).await;
+
// Start task on a daemon
// Find a daemon that belongs to this owner
let mut updated_task = task;