diff --git a/scripts/run_worker.py b/scripts/run_worker.py index 7b9549e..c30c953 100644 --- a/scripts/run_worker.py +++ b/scripts/run_worker.py @@ -2,6 +2,7 @@ import asyncio import concurrent.futures import os from dotenv import load_dotenv +import logging from temporalio.worker import Worker @@ -48,6 +49,9 @@ async def main(): print("===========================================================\n") print("Worker ready to process tasks!") + logging.basicConfig(level=logging.INFO) + + # Run the worker with concurrent.futures.ThreadPoolExecutor(max_workers=100) as activity_executor: