.

Author: rguan72

backend/onyx/utils/threadpool_concurrency.py

@@ -289,8 +289,8 @@ def run_async_sync(coro: Awaitable[T]) -> T:
     context = contextvars.copy_context()
     with concurrent.futures.ThreadPoolExecutor(max_workers=1) as executor:
         future: concurrent.futures.Future[T] = executor.submit(
-+            context.run, asyncio.run, coro
-+       )
+            context.run, asyncio.run, coro
+        )
         return future.result()
 
 class TimeoutThread(threading.Thread, Generic[R]):