Open
Description
I'm calling aiokafka directly to work around limitations of the faust abstractions. I've run into the following stack trace (output thanks to PYTHONASYNCIODEBUG=1). It seems to happen after I've consumed all messages from a couple topics, subscribed to two topics (one the same as before and another), changed the position within the topics and then called getone(). Is there something obviously wrong?
Executing <Handle <TaskWakeupMethWrapper object at 0x7f76975e85b8>(<Future finis...events.py:275>) created at /srv/venvs/service/tr[13/1948]
ice_venv_python3.6/lib/python3.6/site-packages/aiokafka/consumer/fetcher.py:439> took 1.332 seconds
Task was destroyed but it is pending!
source_traceback: Object created at (most recent call last):
File "./async_updater.py", line 201, in <module>
run_async()
File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/click/core.py", line 722, in __call__
return self.main(*args, **kwargs)
File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/click/core.py", line 697, in main
rv = self.invoke(ctx)
File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/click/core.py", line 895, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/click/core.py", line 535, in invoke
return callback(*args, **kwargs)
File "./async_updater.py", line 196, in run_async
loop.run_until_complete(conductor.run())
File "/usr/lib/python3.6/asyncio/base_events.py", line 454, in run_until_complete
self.run_forever()
File "/usr/lib/python3.6/asyncio/base_events.py", line 421, in run_forever
self._run_once()
File "/usr/lib/python3.6/asyncio/base_events.py", line 1418, in _run_once
handle._run()
File "/usr/lib/python3.6/asyncio/events.py", line 127, in _run
self._callback(*self._args)
File "/usr/lib/python3.6/asyncio/coroutines.py", line 125, in send
return self.gen.send(value)
File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/aiokafka/consumer/group_coordinator.py", line 149, in _
reset_committed_routine
commit_refresh_needed.wait(), loop=self._loop)
task: <Task pending coro=<Event.wait() running at /usr/lib/python3.6/asyncio/locks.py:271> wait_for=<Future pending cb=[<TaskWakeupMethWrapp
er object at 0x7f76af3e8be8>()] created at /usr/lib/python3.6/asyncio/base_events.py:275> created at /srv/venvs/service/trusty/service_venv_
python3.6/lib/python3.6/site-packages/aiokafka/consumer/group_coordinator.py:149>
Executing <Handle <TaskWakeupMethWrapper object at 0x7f76971a4e28>(<Future finis...events.py:275>) created at /usr/lib/python3.6/asyncio/tas
ks.py:390> took 0.108 seconds
Metadata
Metadata
Assignees
Labels
No labels