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

Error upon start up on faust==1.0.12 #112

Closed
vineetgoel opened this issue Jun 7, 2018 · 0 comments
Closed

Error upon start up on faust==1.0.12 #112

vineetgoel opened this issue Jun 7, 2018 · 0 comments

Comments

@vineetgoel
Copy link
Contributor

I get the following error when running faust 1.0.12:

Traceback (most recent call last):
  File "/home/robinhood/env/lib/python3.6/site-packages/mode/services.py", line 685, in _execute_task
    await task
  File "/home/robinhood/env/lib/python3.6/site-packages/faust/transport/consumer.py", line 292, in _commit_handler
    await self.commit()
  File "/home/robinhood/env/lib/python3.6/site-packages/faust/transport/consumer.py", line 331, in commit
    return await self.force_commit(topics)
  File "/home/robinhood/env/lib/python3.6/site-packages/mode/services.py", line 417, in _and_transition
    return await fun(self, *args, **kwargs)
  File "/home/robinhood/env/lib/python3.6/site-packages/faust/transport/consumer.py", line 345, in force_commit
    did_commit = await self._commit_tps(commit_tps)
  File "/home/robinhood/env/lib/python3.6/site-packages/faust/transport/consumer.py", line 355, in _commit_tps
    await self._handle_attached(commit_offsets)
  File "/home/robinhood/env/lib/python3.6/site-packages/faust/transport/consumer.py", line 389, in _handle_attached
    await producer.wait_many(pending)
  File "/home/robinhood/env/lib/python3.6/site-packages/mode/services.py", line 600, in wait_many
    return await self._wait_one(coro, timeout=timeout)
  File "/home/robinhood/env/lib/python3.6/site-packages/mode/services.py", line 625, in _wait_one
    f.result()  # propagate exceptions
  File "/home/robinhood/python-3.6.3/lib/python3.6/asyncio/tasks.py", line 304, in wait
    raise ValueError('Set of coroutines/Futures is empty.')
ValueError: Set of coroutines/Futures is empty.

The app crashes after this error.

@jbinney jbinney unassigned ask Jul 31, 2018
Adir-Shemesh pushed a commit to Adir-Shemesh/faust that referenced this issue Jan 10, 2022
…changelog) (robinhood#112)

* fix race (out of order) in flushing topics

* fix style issues

* fix race in ProducerBuffer.flush: fix tests

since the flush functions now simply
wait for the main producer loop to send the messages, we have to
mock this behaviour in the tests, too

Co-authored-by: Tobias Rauter <tobias.rauter@smaxtec.com>
Co-authored-by: Vikram Patki <54442035+patkivikram@users.noreply.github.com>
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

2 participants