sleep

dragonflydb · Sep 24, 2024 · e54f458 · e54f458
1 parent 2cf4543
commit e54f458
Showing 1 changed file with 2 additions and 0 deletions.
diff --git 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