From b850c383758c5906d26cae464ee385d661267a31 Mon Sep 17 00:00:00 2001 From: Orange Kao Date: Fri, 9 Aug 2024 04:26:51 +0000 Subject: [PATCH] Avoid busy retry 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. --- test/test_admin_integration.py | 1 + test/test_consumer_group.py | 1 + 2 files changed, 2 insertions(+) diff --git a/test/test_admin_integration.py b/test/test_admin_integration.py index 283023049..0eb06b18d 100644 --- 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 index ed6863fa2..abd0cfe09 100644 --- 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()