Cloud/deployable temporal example

examples/temporal/router.py

@@ -38,12 +38,9 @@ class RouterWorkflow(Workflow[str]):
     """
 
     @app.workflow_run
-    async def run(self, input: str) -> WorkflowResult[str]:
+    async def run(self) -> WorkflowResult[str]:
         """
-        Run the workflow, processing the input data.
-
-        Args:
-            input_data: The data to process
+        Run the workflow, routing to the correct agents.
 
         Returns:
             A WorkflowResult containing the processed data
@@ -81,7 +78,7 @@ async def run(self, input: str) -> WorkflowResult[str]:
         # You can use any LLM with an LLMRouter
         llm = OpenAIAugmentedLLM(name="openai_router", instruction="You are a router")
         router = LLMRouter(
-            llm=llm,
+            llm_factory=lambda _agent: llm,
             agents=[finder_agent, writer_agent, reasoning_agent],
             functions=[print_to_console, print_hello_world],
             context=app.context,
@@ -150,7 +147,6 @@ async def main():
 
         handle = await executor.start_workflow(
             "RouterWorkflow",
-            None,
         )
         a = await handle.result()
         print(a)

examples/temporal/run_worker.py

@@ -9,13 +9,8 @@
 import asyncio
 import logging
 
+import workflows  # noqa: F401
 from main import app
-from basic import SimpleWorkflow  # noqa: F401
-from evaluator_optimizer import EvaluatorOptimizerWorkflow  # noqa: F401
-from orchestrator import OrchestratorWorkflow  # noqa: F401
-from parallel import ParallelWorkflow  # noqa: F401
-from router import RouterWorkflow  # noqa: F401
-from interactive import WorkflowWithInteraction  # noqa: F401
 
 from mcp_agent.executor.temporal import create_temporal_worker_for_app
 

examples/temporal/workflows.py

@@ -0,0 +1,6 @@
+from basic import SimpleWorkflow  # noqa: F401
+from evaluator_optimizer import EvaluatorOptimizerWorkflow  # noqa: F401
+from orchestrator import OrchestratorWorkflow  # noqa: F401
+from parallel import ParallelWorkflow  # noqa: F401
+from router import RouterWorkflow  # noqa: F401
+from interactive import WorkflowWithInteraction  # noqa: F401