update_task_status
Update task execution status in Netflix Conductor workflows to track progress, mark completion, or report failures during workflow troubleshooting.
Instructions
Update the status of a task execution. This is typically used by workers to update task status.
Input Schema
TableJSON Schema
| Name | Required | Description | Default |
|---|---|---|---|
| taskId | Yes | The unique task execution ID | |
| workflowInstanceId | Yes | The workflow instance ID | |
| status | Yes | New task status | |
| output | No | Task output data | |
| logs | No | Task execution logs |
Implementation Reference
- src/index.ts:1084-1105 (handler)The core handler function that implements the update_task_status tool. It constructs a task update object and sends a POST request to the Conductor API's /tasks endpoint to update the task status, output, and logs.
case "update_task_status": { const { taskId, workflowInstanceId, status, output = {}, logs = [] } = args as any; const taskUpdate = { workflowInstanceId, taskId, status, outputData: output, logs, }; await conductorClient.post("/tasks", taskUpdate); return { content: [ { type: "text", text: `Task ${taskId} status updated to ${status} successfully.`, }, ], }; } - src/index.ts:482-516 (schema)The tool schema definition providing the name, description, and input validation schema for the update_task_status tool, used for tool discovery and parameter validation.
{ name: "update_task_status", description: "Update the status of a task execution. This is typically used by workers to update task status.", inputSchema: { type: "object", properties: { taskId: { type: "string", description: "The unique task execution ID", }, workflowInstanceId: { type: "string", description: "The workflow instance ID", }, status: { type: "string", description: "New task status", enum: ["IN_PROGRESS", "FAILED", "FAILED_WITH_TERMINAL_ERROR", "COMPLETED"], }, output: { type: "object", description: "Task output data", }, logs: { type: "array", description: "Task execution logs", items: { type: "object", }, }, }, required: ["taskId", "workflowInstanceId", "status"], }, }, - src/index.ts:598-602 (registration)The request handler for listing tools, which returns the tools array containing the update_task_status tool definition, effectively registering it for discovery.
server.setRequestHandler(ListToolsRequestSchema, async () => { return { tools, }; });