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