Conductor MCP Server

Instructions

Implementation Reference

• src/index.ts:959-973 (handler)

  Executes the retry_workflow tool by sending a POST request to Conductor's /workflow/{workflowId}/retry endpoint with optional resumeSubworkflowTasks parameter. Returns success message.

  case "retry_workflow": {
    const { workflowId, resumeSubworkflowTasks = false } = args as any;
    await conductorClient.post(`/workflow/${workflowId}/retry`, null, {
      params: { resumeSubworkflowTasks },
    });
    
    return {
      content: [
        {
          type: "text",
          text: `Workflow ${workflowId} retry initiated successfully.`,
        },
      ],
    };
  }

• src/index.ts:346-363 (schema)

  Defines the tool schema including name, description, and input schema requiring workflowId (string) and optional resumeSubworkflowTasks (boolean). This also serves as registration in the tools array.

    name: "retry_workflow",
    description:
      "Retry a failed workflow execution from the last failed task.",
    inputSchema: {
      type: "object",
      properties: {
        workflowId: {
          type: "string",
          description: "The workflow execution ID to retry",
        },
        resumeSubworkflowTasks: {
          type: "boolean",
          description: "Resume subworkflow tasks (default: false)",
        },
      },
      required: ["workflowId"],
    },
  },

• src/index.ts:598-602 (registration)

  Registers all tools including retry_workflow by returning the tools array in response to ListToolsRequestSchema.

  server.setRequestHandler(ListToolsRequestSchema, async () => {
    return {
      tools,
    };
  });