Clarify that the queue-readiness helper returns a coroutine

The second element of the tuple returned by _start_manager_and_wait_for_queues is an already-created coroutine object, not a callable. Naming the local wait_for_queues made �wait wait_for_queues read like a missing call -- it misled an automated reviewer and would mislead a human too. Rename the local to queues_ready and say so in the docstring. No behavior change.

Co-authored-by: Copilot App <223556219+Copilot@users.noreply.github.com>

Copilot-Session: 010b6832-802b-425d-957c-cf29b7143392

Author: Bernd Verst

tests/durabletask/test_worker_concurrency_loop_async.py

@@ -98,7 +98,11 @@ async def run_test():
 
 
 def _start_manager_and_wait_for_queues(manager):
-    """Start the manager loop and wait until its queues are bound to this loop."""
+    """Start the manager loop and return an awaitable that resolves once its queues exist.
+
+    The second element of the returned tuple is an already-created coroutine
+    object (a readiness awaitable), not a callable -- await it directly.
+    """
     worker_task = asyncio.create_task(manager.run())
 
     async def wait_for_queues():
@@ -160,8 +164,8 @@ async def cancel_work(idx):
 
     async def run_test():
         manager.prepare_for_run()
-        worker_task, wait_for_queues = _start_manager_and_wait_for_queues(manager)
-        await wait_for_queues
+        worker_task, queues_ready = _start_manager_and_wait_for_queues(manager)
+        await queues_ready
         assert manager.activity_queue is not None
         for i in range(total_items):
             manager.submit_activity(slow_work, cancel_work, i)
@@ -204,8 +208,8 @@ async def cancel_work(idx):
 
     async def run_test():
         manager.prepare_for_run()
-        worker_task, wait_for_queues = _start_manager_and_wait_for_queues(manager)
-        await wait_for_queues
+        worker_task, queues_ready = _start_manager_and_wait_for_queues(manager)
+        await queues_ready
         queue = manager.activity_queue
         assert queue is not None
         original_task_done = queue.task_done