Fix Python 3.11 coverage threshold

Author: zzstoatzz

pyproject.toml

@@ -92,7 +92,6 @@ addopts = [
     "--numprocesses=logical",
     "--maxprocesses=4",
     "--cov=src/docket",
-    "--cov=tests",
     "--cov-report=term-missing",
     "--cov-branch",
 ]

src/docket/worker.py

@@ -171,16 +171,18 @@ async def run(
                 for task_path in tasks:
                     docket.register_collection(task_path)
 
-                async with Worker(
-                    docket=docket,
-                    name=name,
-                    concurrency=concurrency,
-                    redelivery_timeout=redelivery_timeout,
-                    reconnection_delay=reconnection_delay,
-                    minimum_check_interval=minimum_check_interval,
-                    scheduling_resolution=scheduling_resolution,
-                    schedule_automatic_tasks=schedule_automatic_tasks,
-                ) as worker:
+                async with (
+                    Worker(  # pragma: no branch - context manager exit varies across interpreters
+                        docket=docket,
+                        name=name,
+                        concurrency=concurrency,
+                        redelivery_timeout=redelivery_timeout,
+                        reconnection_delay=reconnection_delay,
+                        minimum_check_interval=minimum_check_interval,
+                        scheduling_resolution=scheduling_resolution,
+                        schedule_automatic_tasks=schedule_automatic_tasks,
+                    ) as worker
+                ):
                     if until_finished:
                         await worker.run_until_finished()
                     else:

tests/test_worker.py

@@ -1756,3 +1756,15 @@ async def test_replace_task_with_legacy_known_key(
     # The key point is that this call succeeds without throwing WRONGTYPE
     replacement_time = now() + timedelta(seconds=1)
     await docket.replace("trace", replacement_time, key=key)("replacement message")
+
+
+async def test_worker_run_classmethod_memory_backend() -> None:
+    """Worker.run should complete immediately when there is no work queued."""
+
+    await Worker.run(
+        docket_name=f"test-run-{uuid4()}",
+        url="memory://",
+        tasks=[],
+        schedule_automatic_tasks=False,
+        until_finished=True,
+    )