tilde-lab / metis-client Goto Github PK

Task exception was never retrieved
future: <Task finished name='StreamConsumerTask' coro=<MetisStreamNamespace._stream_consumer() done, defined at /usr/local/lib/python3.9/dist-packages/metis_client/namespaces/stream.py:34> exception=MetisException("Unexpected exception for 'http://localhost:3000/v0' with - ")>
Traceback (most recent call last):
  File "/usr/local/lib/python3.9/dist-packages/metis_client/client.py", line 131, in _request
    result = await self._session.request(method, url, **aio_opts)
  File "/usr/local/lib/python3.9/dist-packages/aiohttp/client.py", line 560, in _request
    await resp.start(conn)
  File "/usr/local/lib/python3.9/dist-packages/aiohttp/client_reqrep.py", line 899, in start
    message, payload = await protocol.read()  # type: ignore[union-attr]
  File "/usr/local/lib/python3.9/dist-packages/aiohttp/streams.py", line 616, in read
    await self._waiter
asyncio.exceptions.CancelledError

The above exception was the direct cause of the following exception:

Traceback (most recent call last):
  File "/usr/local/lib/python3.9/dist-packages/metis_client/namespaces/stream.py", line 57, in _stream_consumer
    await self._root.v0.ping()
  File "/usr/local/lib/python3.9/dist-packages/metis_client/namespaces/v0.py", line 29, in ping
    await self._client.request(url=self._base_url, method="HEAD", json={})
  File "/usr/local/lib/python3.9/dist-packages/metis_client/client.py", line 157, in _request
    raise MetisException(
metis_client.exc.MetisException: Unexpected exception for 'http://localhost:3000/v0' with -

  File "/home/eb/metis-client/lib/python3.8/site-packages/metis_client/helpers.py",
  line 133, in metis_error_to_raise
    raise err(status=dto["status"], message=msg)
metis_client.exc.MetisError

  ...
  File "/home/eb/metis-client/lib/python3.8/site-packages/asgiref/sync.py", line 218, in __call__
    current_executor.run_until_future(loop_future)
  File "/home/eb/metis-client/lib/python3.8/site-packages/asgiref/current_thread_executor.py", line 59, in run_until_future
    work_item = self._work_queue.get()
  File "/usr/lib/python3.8/queue.py", line 170, in get
    self.not_empty.wait()
  File "/usr/lib/python3.8/threading.py", line 302, in wait
    waiter.acquire()