Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

asyncio.exceptions.CancelledError #974

Open
spff opened this issue Jan 31, 2024 · 0 comments
Open

asyncio.exceptions.CancelledError #974

spff opened this issue Jan 31, 2024 · 0 comments

Comments

@spff
Copy link

spff commented Jan 31, 2024

Describe the bug
A clear and concise description of what the bug is.

Traceback (most recent call last):
  File "venv/lib/python3.9/site-packages/aiokafka/util.py", line 41, in wait_for
    return await fut
asyncio.exceptions.CancelledError

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "venv/lib/python3.9/site-packages/aiokafka/client.py", line 505, in send
    result = await future
  File "venv/lib/python3.9/site-packages/aiokafka/util.py", line 41, in wait_for
    return await fut
  File "venv/lib/python3.9/site-packages/async_timeout/__init__.py", line 129, in __aexit__
    self._do_exit(exc_type)
  File "venv/lib/python3.9/site-packages/async_timeout/__init__.py", line 212, in _do_exit
    raise asyncio.TimeoutError
asyncio.exceptions.TimeoutError

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "venv/lib/python3.9/site-packages/aiokafka/consumer/fetcher.py", line 660, in _proc_fetch_request
    response = await self._client.send(node_id, request)
  File "venv/lib/python3.9/site-packages/aiokafka/client.py", line 510, in send
    raise RequestTimedOutError()
aiokafka.errors.RequestTimedOutError: [Error 7] RequestTimedOutError

During handling of the above exception, another exception occurred:

Traceback (most recent call last):
  File "venv/lib/python3.9/site-packages/aiokafka/consumer/fetcher.py", line 663, in _proc_fetch_request
    await asyncio.sleep(self._retry_backoff)
  File "/usr/lib/python3.9/asyncio/tasks.py", line 652, in sleep
    return await future
asyncio.exceptions.CancelledError

I'm wondering if we can ignore this type of exceptions https://github.com/aio-libs/aiokafka/blob/master/aiokafka/consumer/fetcher.py#L458 as the treatment here https://github.com/aio-libs/aiokafka/blob/master/aiokafka/consumer/fetcher.py#L450

Environment (please complete the following information):

  • aiokafka version (python -c "import aiokafka; print(aiokafka.__version__)"): 0.10.0
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant