Conductor MCP Server

Instructions

Implementation Reference

• src/index.ts:799-821 (handler)

  Handler implementation for the 'list_workflows' tool. Parses input arguments to build query parameters and calls the Conductor /workflow/search API to retrieve matching workflow executions.

  case "list_workflows": {
    const params: any = {
      start: 0,
      size: 100,
    };
    
    if ((args as any).workflowName) params.workflowType = (args as any).workflowName;
    if ((args as any).status) params.status = (args as any).status;
    if ((args as any).startTime) params.startTime = (args as any).startTime;
    if ((args as any).endTime) params.endTime = (args as any).endTime;
    if ((args as any).freeText) params.freeText = (args as any).freeText;
  
    const response = await conductorClient.get("/workflow/search", { params });
    
    return {
      content: [
        {
          type: "text",
          text: JSON.stringify(response.data, null, 2),
        },
      ],
    };
  }

• src/index.ts:197-226 (schema)

  Tool definition including name, description, and input schema for validating parameters used by the list_workflows tool.

    name: "list_workflows",
    description:
      "List workflow executions with optional filters. Returns a list of workflow executions matching the criteria.",
    inputSchema: {
      type: "object",
      properties: {
        workflowName: {
          type: "string",
          description: "Filter by workflow name/type",
        },
        status: {
          type: "string",
          description: "Filter by workflow status (RUNNING, COMPLETED, FAILED, TIMED_OUT, TERMINATED, PAUSED)",
          enum: ["RUNNING", "COMPLETED", "FAILED", "TIMED_OUT", "TERMINATED", "PAUSED"],
        },
        startTime: {
          type: "number",
          description: "Filter workflows started after this time (epoch milliseconds)",
        },
        endTime: {
          type: "number",
          description: "Filter workflows started before this time (epoch milliseconds)",
        },
        freeText: {
          type: "string",
          description: "Free text search across workflow executions",
        },
      },
    },
  },

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

  Registers the list of available tools (including list_workflows) for the MCP list_tools request.

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