From 7c3ad4447b7aed5a56b1021695a91299a3ecec66 Mon Sep 17 00:00:00 2001
From: Deep Koluguri <deepkoluguri@gmail.com>
Date: Mon, 29 Jun 2026 10:34:05 -0400
Subject: [PATCH] Fix worker crash by adding activity executor

---
 src/worker.py | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/src/worker.py b/src/worker.py
index 7d7a57c..32eecb4 100644
--- a/src/worker.py
+++ b/src/worker.py
@@ -4,6 +4,8 @@ from temporalio.worker import Worker
 from src.orchestrator import CentralOrchestratorWorkflow
 from src.agent import run_agent_activity
 
+import concurrent.futures
+
 async def main():
     client = await Client.connect("temporal-frontend.ai-core.svc.cluster.local:7233")
     worker = Worker(
@@ -11,6 +13,7 @@ async def main():
         task_queue="agents-orchestrator",
         workflows=[CentralOrchestratorWorkflow],
         activities=[run_agent_activity],
+        activity_executor=concurrent.futures.ThreadPoolExecutor(max_workers=10),
     )
     print("Starting worker...")
     await worker.run()