From e54f4589a1b5b4b3ef5163b923f5a8e67ae2ae0e Mon Sep 17 00:00:00 2001 From: shahar Date: Tue, 24 Sep 2024 08:46:22 +0300 Subject: [PATCH] sleep --- tests/dragonfly/acl_family_test.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/tests/dragonfly/acl_family_test.py b/tests/dragonfly/acl_family_test.py index d658e70522ce..eb9fb56e95c8 100644 --- a/tests/dragonfly/acl_family_test.py +++ b/tests/dragonfly/acl_family_test.py @@ -710,6 +710,8 @@ async def subscribe_worker(channel: aioredis.client.PubSub): subscriber_obj = subscriber.pubsub() await subscriber_obj.subscribe("channel") + await asyncio.sleep(1) # Check if it's a timing issue + subscribe_task = asyncio.create_task(subscribe_worker(subscriber_obj)) await publish_worker(publisher) await subscribe_task