mirror of
https://github.com/temporal-community/temporal-ai-agent.git
synced 2026-03-15 22:18:09 +01:00
eb06cf5c8d
* Format codebase to satisfy linters * fixing pylance and ruff-checked files * contributing md, and type and formatting fixes * setup file capitalization * test fix
33 lines
842 B
Python
33 lines
842 B
Python
import asyncio
|
|
import concurrent.futures
|
|
|
|
from temporalio.worker import Worker
|
|
|
|
from activities.tool_activities import dynamic_tool_activity
|
|
from shared.config import TEMPORAL_LEGACY_TASK_QUEUE, get_temporal_client
|
|
|
|
|
|
async def main():
|
|
# Create the client
|
|
client = await get_temporal_client()
|
|
|
|
# Run the worker
|
|
with concurrent.futures.ThreadPoolExecutor(max_workers=100) as activity_executor:
|
|
worker = Worker(
|
|
client,
|
|
task_queue=TEMPORAL_LEGACY_TASK_QUEUE,
|
|
activities=[
|
|
dynamic_tool_activity,
|
|
],
|
|
activity_executor=activity_executor,
|
|
)
|
|
|
|
print(
|
|
f"Starting legacy worker, connecting to task queue: {TEMPORAL_LEGACY_TASK_QUEUE}"
|
|
)
|
|
await worker.run()
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|