Skip to content

Commit 31a6b92

Browse files
authored
Avoid busy retry (dpkp#192)
Test test/test_consumer_group.py::test_group and test/test_admin_integration.py::test_describe_consumer_group_exists busy-retry and this might have caused Java not having enough CPU time on GitHub runner, and result in test failure.
1 parent 401896b commit 31a6b92

File tree

2 files changed

+2
-0
lines changed

2 files changed

+2
-0
lines changed

test/test_admin_integration.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -220,6 +220,7 @@ def consumer_thread(i, group_id):
220220
else:
221221
sleep(1)
222222
assert time() < timeout, "timeout waiting for assignments"
223+
sleep(0.25)
223224

224225
info('Group stabilized; verifying assignment')
225226
output = kafka_admin_client.describe_consumer_groups(group_id_list)

test/test_consumer_group.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -111,6 +111,7 @@ def consumer_thread(i):
111111
logging.info('Rejoining: %s, generations: %s', rejoining, generations)
112112
time.sleep(1)
113113
assert time.time() < timeout, "timeout waiting for assignments"
114+
time.sleep(0.25)
114115

115116
logging.info('Group stabilized; verifying assignment')
116117
group_assignment = set()

0 commit comments

Comments
 (0)