update_task_status
Update task execution status in Netflix Conductor workflows. Workers use this tool to mark tasks as in progress, completed, or failed during workflow execution.
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:321-355 (registration)Registers the 'update_task_status' tool including its description and input schema for MCP listTools.{ 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:701-722 (handler)Handler implementation that extracts arguments, builds the task update payload, calls Conductor API to update task status, and returns success response.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.`, }, ], }; }