Avoid busy retry (#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.
wbarnha · Aug 9, 2024 · 31a6b92 · 31a6b92
1 parent 401896b
commit 31a6b92
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/test/test_admin_integration.py b/test/test_admin_integration.py
@@ -220,6 +220,7 @@ def consumer_thread(i, group_id):
                 else:
                     sleep(1)
             assert time() < timeout, "timeout waiting for assignments"
+            sleep(0.25)
 
         info('Group stabilized; verifying assignment')
         output = kafka_admin_client.describe_consumer_groups(group_id_list)

diff --git a/test/test_consumer_group.py b/test/test_consumer_group.py
@@ -111,6 +111,7 @@ def consumer_thread(i):
                     logging.info('Rejoining: %s, generations: %s', rejoining, generations)
                     time.sleep(1)
             assert time.time() < timeout, "timeout waiting for assignments"
+            time.sleep(0.25)
 
         logging.info('Group stabilized; verifying assignment')
         group_assignment = set()