From 6dfbbd9831dc4fea994292246ac1af61aadc1a2f Mon Sep 17 00:00:00 2001 From: shahargl Date: Sun, 8 Sep 2024 15:44:25 +0300 Subject: [PATCH] feat: add logs --- keep/api/api.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/keep/api/api.py b/keep/api/api.py index b5ef08752..d319c04d0 100644 --- a/keep/api/api.py +++ b/keep/api/api.py @@ -271,14 +271,17 @@ async def on_startup(): if KEEP_ARQ_TASK_POOL != KEEP_ARQ_TASK_POOL_NONE: event_loop = asyncio.get_event_loop() if KEEP_ARQ_TASK_POOL == KEEP_ARQ_TASK_POOL_ALL: + logger.info("Starting all task pools") basic_worker = get_arq_worker(KEEP_ARQ_QUEUE_BASIC) ai_worker = get_arq_worker(KEEP_ARQ_QUEUE_AI) event_loop.create_task(basic_worker.async_run()) event_loop.create_task(ai_worker.async_run()) elif KEEP_ARQ_TASK_POOL == KEEP_ARQ_TASK_POOL_AI: + logger.info("Starting AI task pool") arq_worker = get_arq_worker(KEEP_ARQ_QUEUE_AI) event_loop.create_task(arq_worker.async_run()) elif KEEP_ARQ_TASK_POOL == KEEP_ARQ_TASK_POOL_BASIC_PROCESSING: + logger.info("Starting Basic Processing task pool") arq_worker = get_arq_worker(KEEP_ARQ_QUEUE_BASIC) event_loop.create_task(arq_worker.async_run()) else: