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,