Skip to content

feat: Add workflow control, task management, event handlers, resources and prompts#26

Merged
AWOrpington merged 4 commits intoconductor-oss:mainfrom
matteius:feature/add-workflow-control-tools
Jan 8, 2026
Merged

feat: Add workflow control, task management, event handlers, resources and prompts#26
AWOrpington merged 4 commits intoconductor-oss:mainfrom
matteius:feature/add-workflow-control-tools

Conversation

@matteius
Copy link
Contributor

@matteius matteius commented Jan 1, 2026

Summary

This PR adds significant feature parity with an opensensor MCP implementation, extending the conductor-mcp with additional tools, resources, and prompts to provide comprehensive workflow management capabilities.

New Features

Workflow Control Tools

  • pause_workflow: Pause a running workflow execution
  • resume_workflow: Resume a paused workflow execution
  • terminate_workflow: Terminate a workflow execution
  • restart_workflow: Restart a workflow from the beginning
  • retry_workflow: Retry a failed workflow from the last failed task

Task Management Tools

  • get_task_logs: Get execution logs for a specific task
  • update_task_status: Update the status of a task execution
  • create_task_definition: Create or update a task definition

Event Handler Tools

  • get_event_handlers: Get all event handlers with optional filtering by event name and active status

MCP Resources

New resource URIs for read-only access to Conductor data:

  • conductor://workflows/definitions - List all workflow definitions
  • conductor://tasks/definitions - List all task definitions
  • conductor://workflows/running - List running workflow executions
  • conductor://workflows/failed - List failed workflow executions
  • conductor://workflows/paused - List paused workflow executions
  • conductor://tasks/queue - Get task queue status

MCP Prompts

Reusable prompt templates for common operations:

  • troubleshoot_workflow: Guide for troubleshooting failed/stuck workflows
  • analyze_failures: Analyze recent workflow failures and patterns
  • create_workflow: Guide to create new workflow definitions
  • monitor_workflow: Monitor a running workflow execution
  • optimize_workflow: Analyze workflow for optimization opportunities

HTTP Methods

  • Added http_put and http_delete to http_proxy for workflow control operations
  • Added corresponding tests for new HTTP methods

Testing

All existing tests pass, and new tests have been added for the HTTP proxy methods. The server imports successfully with all new modules.

Changes

  • conductor_mcp/network/http_proxy.py: Added http_put and http_delete methods
  • conductor_mcp/tools/workflow.py: Added 5 workflow control tools
  • conductor_mcp/tools/task.py: Added 3 task management tools
  • conductor_mcp/tools/event.py: New module with event handler tool
  • conductor_mcp/resources/conductor.py: New module with 6 MCP resources
  • conductor_mcp/prompts/conductor.py: New module with 5 MCP prompts
  • conductor_mcp/server.py: Mounted new event, resource, and prompt modules
  • conductor_mcp/test/network/http_proxy_test.py: Added tests for http_put and http_delete

Pull Request opened by Augment Code with guidance from the PR author

…s and prompts

This PR adds feature parity with the opensensor MCP implementation:

Workflow Control Tools:
- pause_workflow: Pause a running workflow execution
- resume_workflow: Resume a paused workflow execution
- terminate_workflow: Terminate a workflow execution
- restart_workflow: Restart a workflow from the beginning
- retry_workflow: Retry a failed workflow from the last failed task

Task Management Tools:
- get_task_logs: Get execution logs for a specific task
- update_task_status: Update the status of a task execution
- create_task_definition: Create or update a task definition

Event Handler Tools:
- get_event_handlers: Get all event handlers with optional filtering

MCP Resources:
- conductor://workflows/definitions - List all workflow definitions
- conductor://tasks/definitions - List all task definitions
- conductor://workflows/running - List running workflow executions
- conductor://workflows/failed - List failed workflow executions
- conductor://workflows/paused - List paused workflow executions
- conductor://tasks/queue - Get task queue status

MCP Prompts:
- troubleshoot_workflow: Guide for troubleshooting failed/stuck workflows
- analyze_failures: Analyze recent workflow failures and patterns
- create_workflow: Guide to create new workflow definitions
- monitor_workflow: Monitor a running workflow execution
- optimize_workflow: Analyze workflow for optimization opportunities

HTTP Methods:
- Added http_put and http_delete to http_proxy for workflow control operations
- Added corresponding tests for new HTTP methods
@matteius matteius requested a review from AWOrpington January 7, 2026 17:47
Copy link
Collaborator

@AWOrpington AWOrpington left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Looks good, I just pinned fastmcp in another change: #25 so you can revert that versioning in yours

@matteius matteius force-pushed the feature/add-workflow-control-tools branch from c5e1502 to 1ba33cd Compare January 7, 2026 23:47
@AWOrpington AWOrpington merged commit a0983c0 into conductor-oss:main Jan 8, 2026
1 check passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants