Function call_sync_from_async

openhands/app_server/utils/async_utils.py:10–18

Shorthand for running a function in the default background thread pool executor and awaiting the result. The nature of synchronous code is that the future returned by this function is not cancellable

(fn: Callable, *args, **kwargs)

async def call_sync_from_async(fn: Callable, *args, **kwargs):
    """Shorthand for running a function in the default background thread pool executor
    and awaiting the result. The nature of synchronous code is that the future
    returned by this function is not cancellable
    """
    loop = asyncio.get_event_loop()
    coro = loop.run_in_executor(None, lambda: fn(*args, **kwargs))
    result = await coro
    return result


def call_async_from_sync(