diff --git a/src/app/worker.py b/src/app/worker.py index 1254284..835cc8b 100644 --- a/src/app/worker.py +++ b/src/app/worker.py @@ -1,12 +1,14 @@ import asyncio import uvloop +import logging from arq.connections import RedisSettings from arq.worker import Worker from .core.config import settings asyncio.set_event_loop_policy(uvloop.EventLoopPolicy()) +logging.basicConfig(level=logging.INFO, format="%(asctime)s - %(name)s - %(levelname)s - %(message)s") REDIS_QUEUE_HOST = settings.REDIS_QUEUE_HOST REDIS_QUEUE_PORT = settings.REDIS_QUEUE_PORT @@ -20,11 +22,11 @@ async def sample_background_task(ctx: Worker, name: str) -> str: # -------- base functions -------- async def startup(ctx: Worker) -> None: - print("worker start") + logging.debug("Worker Started") async def shutdown(ctx: Worker) -> None: - print("worker end") + logging.debug("Worker end") # -------- class --------