20 lines
537 B
Python
20 lines
537 B
Python
import asyncio
|
|
from temporalio.client import Client
|
|
from temporalio.worker import Worker
|
|
from src.orchestrator import CentralOrchestratorWorkflow
|
|
from src.agent import run_agent_activity
|
|
|
|
async def main():
|
|
client = await Client.connect("localhost:7233")
|
|
worker = Worker(
|
|
client,
|
|
task_queue="agent-task-queue",
|
|
workflows=[CentralOrchestratorWorkflow],
|
|
activities=[run_agent_activity],
|
|
)
|
|
print("Starting worker...")
|
|
await worker.run()
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|