feat: add reload_workflows tool

Author: ibacalu

src/workflows_mcp/tools.py

@@ -25,7 +25,7 @@
     format_workflow_list_markdown,
     format_workflow_not_found_error,
 )
-from .server import mcp
+from .server import load_workflows, mcp
 
 # =============================================================================
 # MCP Tools (following official SDK decorator pattern)
@@ -496,6 +496,45 @@ async def validate_workflow_yaml(
     }
 
 
+@mcp.tool(
+    annotations=ToolAnnotations(
+        title="Reload Workflows",
+        readOnlyHint=False,  # Modifies server state (registry)
+        destructiveHint=False,
+        idempotentHint=True,  # Repeated calls have same effect
+        openWorldHint=False,
+    )
+)
+async def reload_workflows(
+    *,
+    ctx: AppContextType,
+) -> dict[str, Any]:
+    """Reload all workflows from disk (built-in and user templates)."""
+    # Access shared resources from lifespan context
+    if ctx is None:
+        return {
+            "status": "failure",
+            "message": "Server context not available.",
+        }
+
+    app_ctx = ctx.request_context.lifespan_context
+    registry = app_ctx.registry
+
+    try:
+        load_workflows(registry)
+    except Exception as e:
+        return {
+            "status": "failure",
+            "message": f"Failed to reload workflows: {str(e)}",
+        }
+
+    return {
+        "status": "success",
+        "message": "Successfully reloaded workflows",
+        "total": len(registry.list_names()),
+    }
+
+
 # =============================================================================
 # Checkpoint Management Tools
 # =============================================================================

tests/reproduce_resolver.py

@@ -1,13 +1,12 @@
 import asyncio
-import sys
 import os
-from datetime import datetime
+import sys
 
 # Add src to path
 sys.path.append(os.path.join(os.getcwd(), "src"))
 
+from workflows_mcp.engine.resolver.classifier import ExpressionClassifier
 from workflows_mcp.engine.resolver.unified_resolver import UnifiedVariableResolver
-from workflows_mcp.engine.resolver.classifier import ExpressionClassifier, ExpressionType
 
 
 async def run_test():
@@ -62,7 +61,7 @@ async def run_test():
 
     # Test 3: Pass a dict that contains the expression (simulating Block Definition Inputs)
     # The WorkflowRunner iterates over inputs and resolves them.
-    print(f"\nTest 3: Simulating block definition inputs")
+    print("\nTest 3: Simulating block definition inputs")
     block_inputs = {
         "features": "{{ inputs.features }}",
         "nested": {"prop": "{{ inputs.features.dual_track_enabled }}"},