(fix) use asyncio run_in_executor

2026-08-20 18:24:07 +00:00 · 2024-01-19 09:52:51 -08:00
parent e6b5152e63
commit f2cfb76920
1 changed files with 6 additions and 4 deletions
@@ -2363,10 +2363,12 @@ def client(original_function):
            threading.Thread(
                target=logging_obj.success_handler, args=(result, start_time, end_time)
            ).start()
-            threading.Thread(
-                target=logging_obj.async_success_handler,
-                args=(result, start_time, end_time),
-            ).start()
+
+            loop = asyncio.get_event_loop()
+            loop.run_in_executor(
+                executor=None,
+                func=logging_obj.async_success_handler(result, start_time, end_time),
+            )
            # RETURN RESULT
            if hasattr(result, "_hidden_params"):
                result._hidden_params["model_id"] = kwargs.get("model_info", {}).get(