Eliminate timeout

Author: dandavison

tests/nexus/test_worker.py

@@ -61,19 +61,28 @@ async def op(
     ) as worker:
         await create_nexus_endpoint(worker.task_queue, client)
 
-        coros = [
-            client.execute_workflow(
-                NexusCallerWorkflow.run,
-                i,
-                id=str(uuid.uuid4()),
-                task_queue=worker.task_queue,
+        tasks = [
+            asyncio.create_task(
+                client.execute_workflow(
+                    NexusCallerWorkflow.run,
+                    i,
+                    id=str(uuid.uuid4()),
+                    task_queue=worker.task_queue,
+                )
             )
             for i in range(num_nexus_operations)
         ]
-        try:
-            await asyncio.wait_for(asyncio.gather(*coros), timeout=5)
-        except asyncio.TimeoutError:
-            pass
-        event.set()
-        assert len(set(ids)) == len(ids)
+
+        for _ in range(50):  # 5 seconds max
+            if len(ids) >= expected_num_executed:
+                break
+            await asyncio.sleep(0.1)
+
         assert len(ids) == expected_num_executed
+        assert len(set(ids)) == len(ids)
+
+        event.set()
+        for task in tasks:
+            if not task.done():
+                task.cancel()
+        await asyncio.gather(*tasks, return_exceptions=True)