publish_event is async but seems not very reliable

Author: sanderegg

services/dask-sidecar/tests/unit/test_utils_dask.py

@@ -136,6 +136,7 @@ async def _consumer(event: tuple) -> None:
         received_messages.append(event)
 
     async_dask_client.subscribe_topic(TaskProgressEvent.topic_name(), _consumer)
+    await asyncio.sleep(0)
 
     async def _dask_publisher_task(async_dask_client: distributed.Client) -> None:
         print("--> starting publisher task")