def call_sync()

in datafusion_ray/core.py [0:0]

• 7 lines of code
• 2 McCabe index (conditional complexity)

def call_sync(coro):
    """call a coroutine in the current event loop or run a new one, and synchronously
    return the result"""
    try:
        loop = asyncio.get_running_loop()
    except RuntimeError:
        return asyncio.run(coro)
    else:
        return loop.run_until_complete(coro)