Skip to content

Commit 882979c

Browse files
committed
Mock heartbeat thread start/stop in coordinator fixture
1 parent 8dc9278 commit 882979c

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

test/test_coordinator.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -400,6 +400,8 @@ def patched_coord(mocker, coordinator):
400400
return_value=1)
401401
mocker.patch.object(coordinator._client, 'ready', return_value=True)
402402
mocker.patch.object(coordinator._client, 'send')
403+
mocker.patch.object(coordinator, '_start_heartbeat_thread')
404+
mocker.patch.object(coordinator, '_close_heartbeat_thread')
403405
mocker.spy(coordinator, '_failed_request')
404406
mocker.spy(coordinator, '_handle_offset_commit_response')
405407
mocker.spy(coordinator, '_handle_offset_fetch_response')

0 commit comments

Comments
 (0)