13c14eac076c81227a96e24f749392f5b75aa2ce,python/ray/experimental/async_api.py,,init,#,23

Before Change

    assert ray.is_initialized(), "Please call ray.init before async_api.init"

    // Noop when handler is set.
    if handler is not None:
        return

    loop = asyncio.get_event_loop()
    if loop.is_running():
        if loop._thread_id != threading.get_ident():
            // If the loop is runing outside current thread, we actually need
            // to do this to make sure the context is initialized.
            asyncio.run_coroutine_threadsafe(_async_init(), loop=loop)
        else:
            async_init_done = asyncio.get_event_loop().create_task(
                _async_init())
            // Block until the async init finishes.
            async_init_done.done()
    else:
        asyncio.get_event_loop().run_until_complete(_async_init())

After Change

    assert ray.is_initialized(), "Please call ray.init before async_api.init"

    global handler
    if handler is None:
        worker = ray.worker.global_worker
        loop = asyncio.get_event_loop()
        handler = PlasmaEventHandler(loop, worker)
        worker.core_worker.set_plasma_added_callback(handler)
        logger.debug("AsyncPlasma Connection Created!")


def as_future(object_id):
    Turn an object_id into a Future object.

    Args:

Instances