diff options
Diffstat (limited to 'test/test_fetcher.py')
| -rw-r--r-- | test/test_fetcher.py | 4 |
1 files changed, 0 insertions, 4 deletions
diff --git a/test/test_fetcher.py b/test/test_fetcher.py index a3eea09..b61a0f0 100644 --- a/test/test_fetcher.py +++ b/test/test_fetcher.py @@ -138,10 +138,6 @@ def test__reset_offset(fetcher, mocker): fetcher._subscriptions.need_offset_reset(tp) mocked = mocker.patch.object(fetcher, '_retrieve_offsets') - mocked.return_value = {} - with pytest.raises(NoOffsetForPartitionError): - fetcher._reset_offset(tp) - mocked.return_value = {tp: (1001, None)} fetcher._reset_offset(tp) assert not fetcher._subscriptions.assignment[tp].awaiting_reset |