add headers openai

src/evidently/utils/sync.py

@@ -14,13 +14,46 @@
 
 def async_to_sync(awaitable: Awaitable[TA]) -> TA:
     try:
-        asyncio.get_running_loop()
+        loop = asyncio.get_running_loop()
         # we are in sync context but inside a running loop
+        print(
+            f"loop {loop}",
+        )
         if not _thr.is_alive():
-            _thr.start()
+            print("start loop", loop)
+            # _thr.start()
         future = asyncio.run_coroutine_threadsafe(awaitable, _loop)
         return future.result()
-    except RuntimeError:
+    except RuntimeError as e:
+        print("RuntimeError", e)
+        print("creating new loop")
+        new_loop = asyncio.new_event_loop()
+        asyncio.set_event_loop(new_loop)
+        try:
+            return new_loop.run_until_complete(awaitable)
+        finally:
+            new_loop.close()
+
+    # def async_to_sync(awaitable: Awaitable[TA]) -> TA:
+    #     try:
+    #         loop = asyncio.get_running_loop()
+    #         # we are in sync context but inside a running loop
+    #         print("loop", loop)
+    #
+    #         if not loop.is_running():
+    #             print("loop is not running", loop)
+    #             new_loop = asyncio.new_event_loop()
+    #             asyncio.set_event_loop(new_loop)
+    #             try:
+    #                 return new_loop.run_until_complete(awaitable)
+    #             finally:
+    #                 new_loop.close()
+    #
+    #         future = asyncio.run_coroutine_threadsafe(awaitable, _loop)
+    #         return future.result()
+
+    except RuntimeError as e:
+        print("RuntimeError, creating new_event_loop", e)
         new_loop = asyncio.new_event_loop()
         asyncio.set_event_loop(new_loop)
         try: