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

Fix for canceled from mode #42

Merged
merged 4 commits into from
Nov 20, 2020
Merged

Fix for canceled from mode #42

merged 4 commits into from
Nov 20, 2020

Conversation

patkivikram
Copy link
Collaborator

@patkivikram patkivikram commented Nov 18, 2020

fixes the issue in faust 678

This also fixes the issue where the consumer stops commuting offsets for a certain topic/partition

@patkivikram patkivikram merged commit 1131106 into master Nov 20, 2020
forsberg added a commit to forsberg/faust-streaming that referenced this pull request Nov 24, 2020
patkivikram added a commit that referenced this pull request May 6, 2021
* Restore testing

A lot of test classes are named test_*, which makes pytest *not* find them by default

* Fix failing unit test after fix for #42

* Restore tests by adding timeout arg

* Restore original behaviour of _wait, don't always wait for signal_recovery_start

* Restore a few of the aiokafka tests

* Restore a few app tests

* Run event path verification in aiokafka driver

* lower minimum code coverage to 59%

* reformat examples/livecheck.py with black

* rename test class to match Test naming pattern

* fix test__resume_streams, as assignment() returns a set

Co-authored-by: Erik Forsberg <erik.forsberg@ferroamp.se>
Co-authored-by: Erik Forsberg <forsberg@ferroamp.com>
Co-authored-by: Vikram Patki <54442035+patkivikram@users.noreply.github.com>
@wbarnha wbarnha deleted the fix_for_canceled branch July 3, 2023 03:09
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

Successfully merging this pull request may close these issues.

2 participants