erdewit / nest_asyncio Goto Github PK

RuntimeError: Attempt to access websocket outside of a relevant context
Attempt to access websocket outside of a relevant context
Traceback (most recent call last):
  File "D:\SmartBot\my_env\SmartBot\telegram.py", line 888, in wa2tg2
    data = await websocket.receive()
  File "C:\Users\Smart\AppData\Local\Programs\Python\Python37-32\lib\site-packages\quart\local.py", line 115, in __getattr__
    return getattr(self._get_current_object(), name)
  File "C:\Users\Smart\AppData\Local\Programs\Python\Python37-32\lib\site-packages\quart\local.py", line 84, in _get_current_object
    return object.__getattribute__(self, '__LocalProxy_local')()
  File "C:\Users\Smart\AppData\Local\Programs\Python\Python37-32\lib\site-packages\quart\globals.py", line 14, in _ctx_lookup
    raise RuntimeError(f"Attempt to access {name} outside of a relevant context")

...
  File "/home/argante/anaconda2/Proyectos 8/beagledwx/dwx.py", line 51, in data_request
    data = list_of_dict_to_dict(loop.run_until_complete(future))
  File "/home/argante/anaconda2/envs/python372/lib/python3.7/site-packages/nest_asyncio.py", line 53, in run_until_complete
    self._check_closed()
AttributeError: 'Loop' object has no attribute '_check_closed'

        ntodo = len(self._ready)
        for i in range(ntodo):
            handle = self._ready.popleft() # throws.
            if handle._cancelled:
                continue

import nest_asyncio;nest_asyncio.apply()  # add this line,  program hangs
import pyppeteer,asyncio
w8="ws://127.0.0.1:9222/devtools/browser/9a23f54e-8338-4166-9f3c-bbc6629c17a4"
loop=asyncio.get_event_loop()
connection =pyppeteer.connection.Connection(w8,loop,0)	   

async def af():
	r=await connection.send('Target.getBrowserContexts')  
	print(r)
	return
loop.run_until_complete(af())

>>python C:/test/atest.py
Traceback (most recent call last):
  File "C:/test/atest.py", line 34, in <module>
    loop.run_until_complete(af())
  File "C:\QGB\Anaconda3\lib\site-packages\nest_asyncio.py", line 89, in run_until_complete
    self._run_once()
  File "C:\QGB\Anaconda3\lib\site-packages\nest_asyncio.py", line 123, in _run_once
    handle._run()
  File "C:\QGB\Anaconda3\lib\site-packages\nest_asyncio.py", line 190, in run
    ctx.run(self._callback, *self._args)
  File "C:\QGB\Anaconda3\lib\site-packages\nest_asyncio.py", line 148, in step
    step_orig(task, exc)
  File "C:\QGB\Anaconda3\lib\asyncio\tasks.py", line 249, in __step
    result = coro.send(None)
  File "C:\QGB\Anaconda3\lib\site-packages\pyppeteer\connection.py", line 70, in _async_send
    while not self._connected:
KeyboardInterrupt
2020-11-29:10:51:53,257 ERROR    [base_events.py:1604] Task exception was never retrieved

================================================= FAILURES =================================================
________________________________________________ test_init _________________________________________________

pyfuncitem = <Function test_init>

    @pytest.mark.tryfirst
    def pytest_pyfunc_call(pyfuncitem):
        funcargs = pyfuncitem.funcargs
        testargs = {arg: funcargs[arg] for arg in pyfuncitem._fixtureinfo.argnames}
    
        if not iscoroutinefunction(pyfuncitem.obj):
            pyfuncitem.obj(**testargs)
            return True
    
        try:
            loop = funcargs["io_loop"]
        except KeyError:
            loop = tornado.ioloop.IOLoop.current()
    
>       loop.run_sync(
            lambda: pyfuncitem.obj(**testargs), timeout=get_test_timeout(pyfuncitem)
        )

/usr/local/lib/python3.9/site-packages/pytest_tornasync/plugin.py:53: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
/usr/local/lib/python3.9/site-packages/tornado/ioloop.py:524: in run_sync
    self.start()
/usr/local/lib/python3.9/site-packages/tornado/platform/asyncio.py:199: in start
    self.asyncio_loop.run_forever()
/usr/local/lib/python3.9/site-packages/nest_asyncio.py:51: in run_forever
    with manage_run(self), manage_asyncgens(self):
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <contextlib._GeneratorContextManager object at 0x111a22760>

    def __enter__(self):
        # do not keep args and kwds alive unnecessarily
        # they are only needed for recreation, which is not possible anymore
        del self.args, self.kwds, self.func
        try:
>           return next(self.gen)
E           TypeError: 'NoneType' object is not an iterator

/usr/local/Cellar/[email protected]/3.9.1_6/Frameworks/Python.framework/Versions/3.9/lib/python3.9/contextlib.py:117: TypeError
========================================= short test summary info ==========================================
FAILED tests/test_jobs.py::test_init - TypeError: 'NoneType' object is not an iterator
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! stopping after 1 failures !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
============================================ 1 failed in 0.51s =============================================

RuntimeError: There is no current event loop in thread 'Thread-2'.

import asyncio
import nest_asyncio
nest_asyncio.apply()  # comment this out to see "correct" behavior


async def raise_exception():
    await asyncio.sleep(0.5)
    print('About to raise error')
    raise RuntimeError("test")


async def main():
    asyncio.create_task(raise_exception())
    while True:
        await asyncio.sleep(0.3)
        print("Loop still running")


def handleException(loop: asyncio.AbstractEventLoop, context: dict):
    print('Unhandled exception in async task, will stop loop. Exception context:\n%s' % (context,))
    loop.stop()


loop = asyncio.get_event_loop()
loop.set_exception_handler(handleException)
try:
    loop.run_until_complete(main())
except Exception as e:
    print('Caught exception from run')
print('Run finished')

Loop still running
About to raise error
Loop still running
Loop still running
Loop still running
...

Loop still running
About to raise error
Unhandled exception in async task, will stop loop. Exception context:
{'message': 'Task exception was never retrieved', 'exception': RuntimeError('test'), 'future': <Task finished name='Task-2' coro=<raise_exception() done, defined at ...:7> exception=RuntimeError('test')>}
Caught exception from run
Run finished

import asyncio
import nest_asyncio

if not True:
    print("applying nest_asyncio")
    nest_asyncio.apply()


async def get_results():
    print("start")
    try:
        await asyncio.sleep(5)
    except asyncio.CancelledError:
        print("cancelled!")
    print("stop")
    return 123


try:
    res = asyncio.run(get_results())
    print("res", res)
except KeyboardInterrupt:
    print("received ctrl-c")
    raise

$ python cancel2.py
applying nest_asyncio
start
^Creceived ctrl-c
Traceback (most recent call last):
  File "cancel2.py", line 20, in <module>
    res = asyncio.run(get_results())
  File "/mnt/c/Users/me/Documents/nest_asyncio/nest_asyncio.py", line 32, in run
    return loop.run_until_complete(future)
  File "/mnt/c/Users/me/Documents/nest_asyncio/nest_asyncio.py", line 64, in run_until_complete
    self._run_once()
  File "/mnt/c/Users/me/Documents/nest_asyncio/nest_asyncio.py", line 87, in _run_once
    event_list = self._selector.select(timeout)
  File "/home/me/miniconda3/envs/aq/lib/python3.8/selectors.py", line 468, in select
    fd_event_list = self._selector.poll(timeout, max_ev)
KeyboardInterrupt

$ python cancel2.py
start
^Ccancelled!
stop
received ctrl-c
Traceback (most recent call last):
  File "cancel2.py", line 20, in <module>
    res = asyncio.run(get_results())
  File "/home/me/miniconda3/envs/aq/lib/python3.8/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "/home/me/miniconda3/envs/aq/lib/python3.8/asyncio/base_events.py", line 603, in run_until_complete
    self.run_forever()
  File "/home/me/miniconda3/envs/aq/lib/python3.8/asyncio/base_events.py", line 570, in run_forever
    self._run_once()
  File "/home/me/miniconda3/envs/aq/lib/python3.8/asyncio/base_events.py", line 1823, in _run_once
    event_list = self._selector.select(timeout)
  File "/home/me/miniconda3/envs/aq/lib/python3.8/selectors.py", line 468, in select
    fd_event_list = self._selector.poll(timeout, max_ev)
KeyboardInterrupt

$ pip list | grep nest_
nest-asyncio                  1.5.1               /mnt/c/Users/me/Documents/nest_asyncio

import asyncio
import functools
import time

import nest_asyncio
nest_asyncio.apply()

def sync(corot):
    """
    Make a synchronous function from an asynchronous one.
    :param corot:
    :return:
    """
    result, = asyncio.get_event_loop().run_until_complete(asyncio.gather(corot))
    return result

async def sync_to_corountine(func, *args, **kw):
    """
    Make a coroutine from a synchronous function.
    """
    try:
        return func(*args, *kw)
    finally:
        # every async needs an await.
        await asyncio.sleep(0)

def main():
    async def background(timeout):
        await asyncio.sleep(timeout)
        print(f"Background: {timeout}")

    loop = asyncio.get_event_loop()
    # Run some bacground work to check we are never blocked
    bg_tasks = [
        loop.create_task(background(i))
        for i in range(10)
    ]



    async def long_running_async_task(result):
        # Simulate slow IO
        print(f"...START long_running_async_task [{result}]")
        await asyncio.sleep(4)
        print(f"...END   long_running_async_task [{result}]")
        return result

    def sync_function_with_async_dependency(result):
        print(f"...START sync_function_with_async_dependency [{result}]")
        result = sync(long_running_async_task(result))
        print(f"...END   sync_function_with_async_dependency [{result}]")
        return result

    # Call sync_function_with_async_dependency
    # One reentrant task is OK
    # Multiple reentrant tasks->fails to exit
    n = 2
    for i in range(n):
       bg_tasks.append(sync_to_corountine(sync_function_with_async_dependency, i))

    # OK
    # bg_tasks.append(long_running_async_task(123))
    # bg_tasks.append(long_running_async_task(456))

    task = asyncio.gather(*bg_tasks)  # , loop=loop)
    loop.run_until_complete(task)

if __name__ == '__main__':
    main()

  File "/Users/maartenbreddels/miniconda3/envs/vaex37-test/lib/python3.7/site-packages/tornado/gen.py", line 712, in __init__
    if self.handle_yield(first_yielded):
  File "/Users/maartenbreddels/miniconda3/envs/vaex37-test/lib/python3.7/site-packages/tornado/gen.py", line 789, in handle_yield
    self.io_loop.add_future(self.future, inner)
  File "/Users/maartenbreddels/miniconda3/envs/vaex37-test/lib/python3.7/site-packages/tornado/ioloop.py", line 693, in add_future
    assert is_future(future)
AssertionError

import asyncio
import nest_asyncio
from websockets import connect

nest_asyncio.apply()

async def _connect():
    websocket = await connect('wss://wss.foo.com:9876')

def client():
    loop = asyncio.get_event_loop()
    return loop.run_until_complete(_connect())

if __name__ == "__main__":
    client()

runtimes/alibi-explain/tests/conftest.py:29: in <module>
    nest_asyncio.apply()
../../.virtualenvs/mlserver-37/lib/python3.7/site-packages/nest_asyncio.py:14: in apply
    raise ValueError('Can\'t patch loop of type %s' % type(loop))
E   ValueError: Can't patch loop of type <class 'NoneType'>

Traceback (most recent call last):
  File "/Users/yuriikarabas/PycharmProjects/sandbox/main.py", line 17, in <module>
    run(main())
  File "/Library/Frameworks/Python.framework/Versions/3.9/lib/python3.9/asyncio/runners.py", line 44, in run
    return loop.run_until_complete(main)
  File "/Users/yuriikarabas/PycharmProjects/sandbox/venv/lib/python3.9/site-packages/nest_asyncio.py", line 98, in run_until_complete
    return f.result()
  File "/Library/Frameworks/Python.framework/Versions/3.9/lib/python3.9/asyncio/futures.py", line 201, in result
    raise self._exception
  File "/Library/Frameworks/Python.framework/Versions/3.9/lib/python3.9/asyncio/tasks.py", line 256, in __step
    result = coro.send(None)
  File "/Users/yuriikarabas/PycharmProjects/sandbox/toy_io.py", line 12, in main
    ctx_var.reset(token)
ValueError: <Token var=<ContextVar name='ctx_var' at 0x7fbde8933ea0> at 0x7fbde8ed4ac0> was created in a different Context

from bottle import route, run, template
import nest_asyncio

@route('/')
def index(name='jack'):
    nest_asyncio.apply()
    return template('<b>Hello {{name}}</b>!', name=name)

run(server='paste', host='localhost', port=8080, debug=True)

Error: 500 Internal Server Error
Sorry, the requested URL 'http://localhost:8080/' caused an error:

Internal Server Error
Exception: RuntimeError("There is no current event loop in thread 'worker 0'.")

Traceback:
Traceback (most recent call last):
  File "c:\Users\env\lib\site-packages\bottle.py", line 868, in _handle
    return route.call(**args)
  File "c:\Users\env\lib\site-packages\bottle.py", line 1748, in wrapper
    rv = callback(*a, **ka)
  File "c:\Users\mybottle.py", line 5, in index
    nest_asyncio.apply()
  File "c:\Users\env\lib\site-packages\nest_asyncio.py", line 12, in apply
    loop = loop or asyncio.get_event_loop()
  File "C:\Users\AppData\Local\Programs\Python\Python39\lib\asyncio\events.py", line 642, in get_event_loop
    raise RuntimeError('There is no current event loop in thread %r.'
RuntimeError: There is no current event loop in thread 'worker 0'.

_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
/home/amos/miniconda3/envs/aq/lib/python3.8/site-packages/testbook/testbook.py:52: in __enter__
    self._prepare()
/home/amos/miniconda3/envs/aq/lib/python3.8/site-packages/testbook/testbook.py:46: in _prepare
    self.client.execute()
/home/amos/miniconda3/envs/aq/lib/python3.8/site-packages/testbook/client.py:147: in execute
    super().execute_cell(cell, index)
/home/amos/miniconda3/envs/aq/lib/python3.8/site-packages/nbclient/util.py:74: in wrapped
    return just_run(coro(*args, **kwargs))
/home/amos/miniconda3/envs/aq/lib/python3.8/site-packages/nbclient/util.py:53: in just_run
    return loop.run_until_complete(coro)
/home/amos/miniconda3/envs/aq/lib/python3.8/asyncio/base_events.py:616: in run_until_complete
    return future.result()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _

self = <testbook.client.TestbookNotebookClient object at 0x7fc0bcd87670>
cell = {'cell_type': 'code', 'execution_count': None, 'id': '6765142a', 'metadata': {'execution': {}}, 'outputs': [], '<snip>
cell_index = 6, execution_count = None, store_history = True

    async def async_execute_cell(
            self,
            cell: NotebookNode,
            cell_index: int,
            execution_count: t.Optional[int] = None,
            store_history: bool = True) -> NotebookNode:
        """
        Executes a single code cell.

        To execute all cells see :meth:`execute`.

        Parameters
        ----------
        cell : nbformat.NotebookNode
            The cell which is currently being processed.
        cell_index : int
            The position of the cell within the notebook object.
        execution_count : int
            The execution count to be assigned to the cell (default: Use kernel response)
        store_history : bool
            Determines if history should be stored in the kernel (default: False).
            Specific to ipython kernels, which can store command histories.

        Returns
        -------
        output : dict
            The execution output payload (or None for no output).

        Raises
        ------
        CellExecutionError
            If execution failed and should raise an exception, this will be raised
            with defaults about the failure.

        Returns
        -------
        cell : NotebookNode
            The cell which was just processed.
        """
        assert self.kc is not None
        if cell.cell_type != 'code' or not cell.source.strip():
            self.log.debug("Skipping non-executing cell %s", cell_index)
            return cell

        if self.record_timing and 'execution' not in cell['metadata']:
            cell['metadata']['execution'] = {}

        self.log.debug("Executing cell:\n%s", cell.source)

        cell_allows_errors = (not self.force_raise_errors) and (
            self.allow_errors
            or "raises-exception" in cell.metadata.get("tags", []))

        parent_msg_id = await ensure_async(
            self.kc.execute(
                cell.source,
                store_history=store_history,
                stop_on_error=not cell_allows_errors
            )
        )
        # We launched a code cell to execute
        self.code_cells_executed += 1
        exec_timeout = self._get_timeout(cell)

        cell.outputs = []
        self.clear_before_next_output = False

        task_poll_kernel_alive = asyncio.ensure_future(
            self._async_poll_kernel_alive()
        )
        task_poll_output_msg = asyncio.ensure_future(
            self._async_poll_output_msg(parent_msg_id, cell, cell_index)
        )
        self.task_poll_for_reply = asyncio.ensure_future(
            self._async_poll_for_reply(
                parent_msg_id, cell, exec_timeout, task_poll_output_msg, task_poll_kernel_alive
            )
        )
        try:
            exec_reply = await self.task_poll_for_reply
        except asyncio.CancelledError:
            # can only be cancelled by task_poll_kernel_alive when the kernel is dead
            task_poll_output_msg.cancel()
>           raise DeadKernelError("Kernel died")
E           nbclient.exceptions.DeadKernelError: Kernel died

/home/amos/miniconda3/envs/aq/lib/python3.8/site-packages/nbclient/client.py:845: DeadKernelError

import asyncio
import nest_asyncio


async def nested_function():
   print("Nested function called")
   await asyncio.sleep(1)

async def crashing_function():
   print("Launching crashing function")
   await asyncio.sleep(0.01)
   raise RuntimeError("This thing crashed")

def recursive_function():
   print("Initial")
   loop = asyncio.get_running_loop()
   loop.run_until_complete(nested_function())

async def calls_recursive():
   await asyncio.sleep(0.01)
   recursive_function()

async def async_main():
   print("Async main")
   nest_asyncio.apply(loop)
   tasks = [calls_recursive(), crashing_function()]
   print("Async main resuming")
   await asyncio.gather(*tasks)

loop = asyncio.get_event_loop()
loop.run_until_complete(async_main())

  File "/home/travis/virtualenv/python3.5.6/lib/python3.5/site-packages/nest_asyncio.py", line 62, in run_forever
    old_agen_hooks = sys.get_asyncgen_hooks()
AttributeError: module 'sys' has no attribute 'get_asyncgen_hooks'

import asyncio
import datetime
import nest_asyncio
nest_asyncio.apply()

async def display_date(loop):
    end_time = loop.time() + 5.0
    while True:
        print(datetime.datetime.now())
        if (loop.time() + 1.0) >= end_time:
            break
        await asyncio.sleep(1)


loop = asyncio.get_event_loop()
# Blocking call which returns when the display_date() coroutine is done
loop.run_until_complete(display_date(loop))
loop.close()

---------------------------------------------------------------------------
RuntimeError                              Traceback (most recent call last)
<ipython-input-9-c73182512528> in <module>
     16 # Blocking call which returns when the display_date() coroutine is done
     17 loop.run_until_complete(display_date(loop))
---> 18 loop.close()

~\Anaconda3\lib\asyncio\selector_events.py in close(self)
     81     def close(self):
     82         if self.is_running():
---> 83             raise RuntimeError("Cannot close a running event loop")
     84         if self.is_closed():
     85             return

RuntimeError: Cannot close a running event loop

await asyncio.wait([sent, received])


print('finished! main')

import nest_asyncio
nest_asyncio.apply() 

import time
import binascii
import can
from can.interfaces.vector import VectorBus
import asyncio
import aioisotp

async def infinite(rdr):
    while True:
        payload = await rdr.read(4095)
        print("inf_rdr:", binascii.hexlify(payload).decode())
        
async def main(): 
    network = aioisotp.ISOTPNetwork(0,
                                    interface='vector',
                                    receive_own_messages=False, tx_padding=0x0)
    with network.open():
        reader, writer = await network.open_connection(0x7BB, 0x7B3)
        reader1, writer1 = await network.open_connection(0x728, 0x720)
        reader2, writer2 = await network.open_connection(0x7DF, 0x7DF)
        asyncio.create_task(infinite(reader))
        asyncio.create_task(infinite(reader1))

        writer2.write(b'\x22\xF1\x13')

        await asyncio.sleep(6.5) # The read() in infinite() does not complete until this times out
    await asyncio.sleep(0.5)
    
if __name__ == "__main__":
    asyncio.run(main())

loop.run_until_complete(task1)
 ...  loop.run_until_complete(task11)
loop.run_until_complete(task2)
 ...   loop.run_until_complete(task12)
loop.run_until_complete(task3)
 ...   loop.run_until_complete(task13)
loop.run_until_complete(task4)
 ...   loop.run_until_complete(task14)

# None of the nested tasks complete until the slowest (last) nested task completes

loop.run_until_complete(nested_task)

import asyncio
import time
from random import randint
import nest_asyncio
nest_asyncio.apply()

def sync2async(f, *args, **kw):
    async def _f():
        return f(*args, **kw)
    return _f()

def sync(f, loop, args=(), kw={}):
    """
    Execute a non-async function in the event loop
    Generally, the function should not be IO bound unless
    it also submits the IO task to the loop.
    """
    return loop.run_until_complete(sync2async(f, *args, **kw))


async def async_db_execution(query_param, sleep=1):
    await asyncio.sleep(sleep)
    dbresult = randint(0,100)
    return query_param

def original_sync_implementation(query_param, sleep):
    # .... non-blocking sync stuff

    # async call to DB -- this thread does not block!
    # But, whomp, whomp, blocks until ALL tasks in the loop are complete,
    # not just the one submitted.
    tstart = time.time()
    result = loop.run_until_complete(async_db_execution(query_param=query_param, sleep=sleep))
    print("DB task complete should take {}, but took {}".format(sleep, time.time()-tstart))
    # Could also replace this with threaded execution!
    # loop.run_in_executor()

    # .... more non-blocking sync stuff
    return result

async def async_rest_endpoint(query_param=1, sleep=2):
    # Simulate slow IO-bound task
    # Has non-syncio markup implementation
    # but DB access is with asyncio
    print(f"...START long_running_async_task [{query_param} {sleep}]")
    result =sync(original_sync_implementation,
                 kw=dict(query_param=query_param, sleep=sleep),
                 loop=loop)
    print(f"...END   long_running_async_task [{query_param} {sleep}]")
    return result


loop = asyncio.get_event_loop()
task = asyncio.gather(*[
    loop.create_task(async_rest_endpoint(query_param=i, sleep=1+(i%2)))
    # loop.create_task(long_running_async_task())
    for i in range(10)
])
loop.run_until_complete(task)

print("DONE")

...START long_running_async_task [0 1]
...START long_running_async_task [1 2]
...START long_running_async_task [2 1]
...START long_running_async_task [3 2]
...START long_running_async_task [4 1]
...START long_running_async_task [5 2]
...START long_running_async_task [6 1]
...START long_running_async_task [7 2]
...START long_running_async_task [8 1]
...START long_running_async_task [9 2]
DB task complete after 2, should be 2.002359390258789
DB task complete after 1, should be 2.002471685409546
DB task complete after 2, should be 2.002546548843384
DB task complete after 1, should be 2.0026204586029053
DB task complete after 2, should be 2.0026872158050537
DB task complete after 1, should be 2.002741575241089
DB task complete after 2, should be 2.002797842025757
DB task complete after 1, should be 2.0028557777404785
DB task complete after 2, should be 2.0029075145721436
DB task complete after 1, should be 2.0029778480529785
...END   long_running_async_task [9 2]
...END   long_running_async_task [8 1]
...END   long_running_async_task [7 2]
...END   long_running_async_task [6 1]
...END   long_running_async_task [5 2]
...END   long_running_async_task [4 1]
...END   long_running_async_task [3 2]
...END   long_running_async_task [2 1]
...END   long_running_async_task [1 2]
...END   long_running_async_task [0 1]
DONE   # ~ 2 seconds

def run_all(loop)
      while True: 
           try: 
                t = loop.queue.next_signalled_unblocked()
                t.execute_until_yield_or_return()
                if t.complete: 
                     loop.queue.remove(t)
                     return t.result
                else: continue    
           except Empty:
                return

def run_until_complete(loop, task)
      queue.push(task)
      run_all(loop)
      return task.result

def run_until_complete(loop, task)
      loop.queue.push(task)
      while True: 
           try: 
                t = loop.queue.next_signalled_unblocked()
                t.execute_until_yield_or_return()
                if t.complete: 
                     loop.queue.remove(t)
                    return t.result
                else: continue  # run something else
             
           except Empty:
                return

Exception in callback Task.__wakeup(<Future finished result=None>)
handle: <Handle Task.__wakeup(<Future finished result=None>)>
Traceback (most recent call last):
  File "/usr/local/lib/python3.7/dist-packages/nest_asyncio.py", line 150, in run
    ctx.run(self._callback, *self._args)
  File "/usr/lib/python3.7/asyncio/tasks.py", line 303, in __wakeup
    self.__step()
  File "/usr/local/lib/python3.7/dist-packages/nest_asyncio.py", line 108, in step
    step_orig(task, exc)
  File "/usr/lib/python3.7/asyncio/tasks.py", line 287, in __step
    _leave_task(self._loop, self)
  File "/usr/local/lib/python3.7/dist-packages/nest_asyncio.py", line 122, in leave_task
    del curr_tasks[loop]
KeyError: <_UnixSelectorEventLoop running=False closed=False debug=False>

      Traceback:
      File "/usr/local/lib/python3.8/dist-packages/nest_asyncio.py", line 190, in run
        ctx.run(self._callback, *self._args)
      File "/usr/local/lib/python3.8/dist-packages/nest_asyncio.py", line 148, in step
        step_orig(task, exc)
      File "/usr/lib/python3.8/asyncio/tasks.py", line 319, in __step
        if self._fut_waiter.cancel():
      File "/usr/lib/python3.8/asyncio/tasks.py", line 254, in cancel
        if self._fut_waiter.cancel():
      File "/usr/lib/python3.8/asyncio/tasks.py", line 707, in cancel
        if child.cancel():
      File "/usr/lib/python3.8/asyncio/tasks.py", line 254, in cancel
        if self._fut_waiter.cancel():
      File "/usr/lib/python3.8/asyncio/tasks.py", line 254, in cancel
        if self._fut_waiter.cancel():
      File "/usr/lib/python3.8/asyncio/tasks.py", line 707, in cancel
        if child.cancel():
      ...
      File "/usr/lib/python3.8/asyncio/tasks.py", line 254, in cancel
        if self._fut_waiter.cancel():
      File "/usr/lib/python3.8/asyncio/tasks.py", line 250, in cancel
        self._log_traceback = False
      File "/usr/lib/python3.8/asyncio/futures.py", line 112, in _log_traceback
        if bool(val):
    <class 'RecursionError'>
    maximum recursion depth exceeded while calling a Python object

Traceback (most recent call last):
  File "/Users/maartenbreddels/miniconda3/envs/dev/lib/python3.7/site-packages/nest_asyncio.py", line 149, in run
    ctx.run(self._callback, *self._args)
RuntimeError: Cannot enter into task <Task pending coro=<_debounced_callable.__call__.<locals>.debounced_execute.<locals>.run_async() running at /Users/maartenbreddels/src/vaex/packages/vaex-core/vaex/jupyter/utils.py:149>> while another task <Task pending coro=<InteractiveShell.run_cell_async() running at /Users/maartenbreddels/miniconda3/envs/dev/lib/python3.7/site-packages/IPython/core/interactiveshell.py:3020> cb=[IPythonKernel._cancel_on_sigint.<locals>.cancel_unless_done(<Future pendi...ernel.py:230]>)() at /Users/maartenbreddels/miniconda3/envs/dev/lib/python3.7/site-packages/ipykernel/ipkernel.py:230, IOLoop.add_future.<locals>.<lambda>() at /Users/maartenbreddels/miniconda3/envs/dev/lib/python3.7/site-packages/tornado/ioloop.py:690]> is being executed.

======================================================================                
ERROR: test_two_run_until_completes_in_one_outer_loop (tests.nest_test.NestTest)
----------------------------------------------------------------------                
Traceback (most recent call last):                                                                                                                                           
  File "/tmp/portage/dev-python/nest_asyncio-1.5.1/work/nest_asyncio-1.5.1/tests/nest_test.py", line 87, in test_two_run_until_completes_in_one_outer_loop                   
    asyncio.gather(f1(), f2(), loop=self.loop))                                       
TypeError: gather() got an unexpected keyword argument 'loop'