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()