From 26c9110e76e27d3c52962b85c8b07d54896e09db Mon Sep 17 00:00:00 2001 From: Ishaan Jaff Date: Fri, 22 Aug 2025 16:49:37 -0700 Subject: [PATCH] add GLOBAL_LOGGING_WORKER for async task handling --- litellm/utils.py | 18 +++++++++++++++--- 1 file changed, 15 insertions(+), 3 deletions(-) diff --git a/litellm/utils.py b/litellm/utils.py index 68390c8c86d..e634e00949f 100644 --- a/litellm/utils.py +++ b/litellm/utils.py @@ -833,10 +833,22 @@ async def _client_async_logging_helper( print_verbose( f"Async Wrapper: Completed Call, calling async_success_handler: {logging_obj.async_success_handler}" ) - # check if user does not want this to be logged - asyncio.create_task( - logging_obj.async_success_handler(result, start_time, end_time) + ################################################ + # Async Logging Worker + ################################################ + from litellm.litellm_core_utils.logging_worker import GLOBAL_LOGGING_WORKER + GLOBAL_LOGGING_WORKER.ensure_initialized_and_enqueue( + async_coroutine = logging_obj.async_success_handler( + result=result, + start_time=start_time, + end_time=end_time + ) ) + + + ################################################ + # Sync Logging Worker + ################################################ logging_obj.handle_sync_success_callbacks_for_async_calls( result=result, start_time=start_time,