x

Author: eyurtsev

langchain_postgres/v2/engine.py

@@ -119,7 +119,7 @@ async def _run_as_async(self, coro: Awaitable[T]) -> T:
             return await coro
         # Otherwise, run in the background thread
         return await asyncio.wrap_future(
-            asyncio.run_coroutine_threadsafe(coro, self._loop)
+            asyncio.run_coroutine_threadsafe(coro, self._loop)  # type: ignore[arg-type]
         )
 
     def _run_as_sync(self, coro: Awaitable[T]) -> T:
@@ -128,7 +128,7 @@ def _run_as_sync(self, coro: Awaitable[T]) -> T:
             raise Exception(
                 "Engine was initialized without a background loop and cannot call sync methods."
             )
-        return asyncio.run_coroutine_threadsafe(coro, self._loop).result()
+        return asyncio.run_coroutine_threadsafe(coro, self._loop).result()  # type: ignore[arg-type]
 
     async def close(self) -> None:
         """Dispose of connection pool"""