diff options
| author | Dana Powers <dana.powers@gmail.com> | 2016-07-16 23:35:06 -0700 |
|---|---|---|
| committer | Dana Powers <dana.powers@gmail.com> | 2016-07-17 08:42:40 -0700 |
| commit | 26eb4e048933b41b09d8d47f8a639baa062958f0 (patch) | |
| tree | 1e2962f2ec351a75b02cdc8ec972aa8e763ff2b8 /test/test_coordinator.py | |
| parent | dd50847a9beaa9490ae35c7b1bc18d0780b92726 (diff) | |
| download | kafka-python-KAFKA-3486.tar.gz | |
KAFKA-3486: fix autocommit when partitions assigned manuallyKAFKA-3486
Diffstat (limited to 'test/test_coordinator.py')
| -rw-r--r-- | test/test_coordinator.py | 5 |
1 files changed, 0 insertions, 5 deletions
diff --git a/test/test_coordinator.py b/test/test_coordinator.py index 280fa70..35598e8 100644 --- a/test/test_coordinator.py +++ b/test/test_coordinator.py @@ -370,10 +370,6 @@ def test_maybe_auto_commit_offsets_sync(mocker, api_version, group_id, enable, side_effect=error) if has_auto_commit: assert coordinator._auto_commit_task is not None - # auto-commit enable is defered until after group join in 0.9+ - if api_version >= (0, 9): - coordinator._auto_commit_task.enable() - assert coordinator._auto_commit_task._enabled is True else: assert coordinator._auto_commit_task is None @@ -381,7 +377,6 @@ def test_maybe_auto_commit_offsets_sync(mocker, api_version, group_id, enable, if has_auto_commit: assert coordinator._auto_commit_task is not None - assert coordinator._auto_commit_task._enabled is False assert commit_sync.call_count == (1 if commit_offsets else 0) assert mock_warn.call_count == (1 if warn else 0) |