[Python][Flaky Test] test_sync_pubsub_combined_exact_pattern_and_sharded_one_client[2-True] #4933
Description
Test Name
TestSyncPubSub.test_sync_pubsub_combined_exact_pattern_and_sharded_one_client[2-True]
Test Location
valkey-glide/python/tests/sync_tests/test_sync_pubsub.py: line 1154
Failure Permlink
https://github.com/valkey-io/valkey-glide/actions/runs/18863028930/job/53825275228#step:8:384
Frequency
No response
Steps to Reproduce
No response
System Information
aarch64-unknown-linux-gnu
Language and Version
Python 3.12
Engine Version
9.0
Logs
tests/sync_tests/test_sync_pubsub.py:1270:
method = <MethodTesting.Callback: 2>
client = <glide_sync.glide_client.GlideClusterClient object at 0xe91ad5b8e0c0>
callback = [PubSubMsg(message=b'ubGtEzZYgm', channel=b'{channel}:lHUSQ', pattern=None), PubSubMsg(message=b'yCEvdCgCHg', channel=...nel=b'{channel}:vAvPw', pattern=None), PubSubMsg(message=b'CSYbwykMVb', channel=b'{channel}:ujWoT', pattern=None), ...]
expected_callback_messages_count = 768
def check_no_messages_left(
method,
client: TGlideClient,
callback: Optional[List[Any]] = None,
expected_callback_messages_count: int = 0,
):
if method == MethodTesting.Async:
# assert there are no messages to read
with pytest.raises(TimeoutError):
run_sync_func_with_timeout_in_thread(
lambda: client.get_pubsub_message(), # This blocks indefinitely
timeout=3.0,
)
elif method == MethodTesting.Sync:
assert client.try_get_pubsub_message() is None
else:
assert callback is not None
assert len(callback) == expected_callback_messages_count
E AssertionError: assert 767 == 768
E + where 767 = len([PubSubMsg(message=b'ubGtEzZYgm', channel=b'{channel}:lHUSQ', pattern=None), PubSubMsg(message=b'yCEvdCgCHg', channel=b'{channel}:REiPH', pattern=None), PubSubMsg(message=b'BSRYHWtZcj', channel=b'{channel}:eVPMu', pattern=None), PubSubMsg(message=b'dGJpnmALzY', channel=b'{channel}:Bcaue', pattern=None), PubSubMsg(message=b'ZTJzNZhDit', channel=b'{channel}:vAvPw', pattern=None), PubSubMsg(message=b'CSYbwykMVb', channel=b'{channel}:ujWoT', pattern=None), ...])
tests/sync_tests/test_sync_pubsub.py:126: AssertionError
Screenshots
No response
Glide Version
main
Expected Behavior
No response
Actual Behavior
No response
Possible Fixes
No response