summaryrefslogtreecommitdiff
path: root/subagents/workflow.lua
diff options
context:
space:
mode:
Diffstat (limited to 'subagents/workflow.lua')
-rw-r--r--subagents/workflow.lua3
1 files changed, 3 insertions, 0 deletions
diff --git a/subagents/workflow.lua b/subagents/workflow.lua
index 97dd858..671890e 100644
--- a/subagents/workflow.lua
+++ b/subagents/workflow.lua
@@ -767,6 +767,7 @@ local function finish_workflow(record, status, result, err)
record.error = err
record.coroutine = nil
active_workflows[record.id] = nil
+ progress.workflow_finished(record.tool_call_id)
notify(record)
end
@@ -785,6 +786,7 @@ function M.start(wf, opts)
workflow_sequence = workflow_sequence + 1
local id = "workflow-" .. workflow_sequence
local record = make_workflow_record(id)
+ record.tool_call_id = type(opts.tool_call_id) == "string" and opts.tool_call_id ~= "" and opts.tool_call_id or nil
workflow_records[id] = record
active_workflows[id] = record
@@ -823,6 +825,7 @@ function M.start(wf, opts)
finish_workflow(record, record.cancel_requested and "cancelled" or "failed", nil, tostring(err))
end
end)
+ progress.workflow_started(record.tool_call_id)
return id
end