def callback() -> None:
    'Handle the call to the coroutine.'
    try:
        _chain_future(ensure_future(coro, loop=loop), future)
    except Exception as exc:
        if future.set_running_or_notify_cancel():
            future.set_exception(exc)
        else:
            _LOGGER.warning('Exception on lost future: ', exc_info=True)
Handle the call to the coroutine.
def callback() -> None:
    
    try:
        _chain_future(ensure_future(coro, loop=loop), future)
    except Exception as exc:
        if future.set_running_or_notify_cancel():
            future.set_exception(exc)
        else:
            _LOGGER.warning('Exception on lost future: ', exc_info=True)