Add brief comment, rename slow_task to waiting_task

The function never sleeps anymore — it waits on an Event() that's never
set — so "slow" was misleading. waiting_task names what it actually does.

Author: DABH

tests/contrib/langgraph/e2e_functional_entrypoints.py

@@ -133,12 +133,13 @@ async def interrupt_entrypoint(value: str) -> dict:
 
 
 @task
-async def slow_task(x: int) -> int:
+async def waiting_task(x: int) -> int:
+    # Wait (forever) until start_to_close_timeout or worker shutdown cancellation
     await asyncio.Event().wait()
     return x
 
 
 @entrypoint()
 async def slow_entrypoint(value: int) -> dict:
-    result = await slow_task(value)
+    result = await waiting_task(value)
     return {"result": result}

tests/contrib/langgraph/test_e2e_functional.py

@@ -46,7 +46,7 @@
     reset_task_execution_counts,
     simple_functional_entrypoint,
     slow_entrypoint,
-    slow_task,
+    waiting_task,
     step_1,
     step_2,
     step_3,
@@ -316,10 +316,10 @@ async def test_per_task_activity_options_override(self, client: Client) -> None:
             plugins=[
                 LangGraphPlugin(
                     entrypoints={"e2e_slow_functional": slow_entrypoint},
-                    tasks=[slow_task],
+                    tasks=[waiting_task],
                     default_activity_options=_DEFAULT_ACTIVITY_OPTIONS,
                     activity_options={
-                        "slow_task": {
+                        "waiting_task": {
                             "execute_in": "activity",
                             "start_to_close_timeout": timedelta(milliseconds=100),
                             "retry_policy": RetryPolicy(maximum_attempts=1),

tests/contrib/langgraph/test_timeout.py

@@ -19,6 +19,7 @@ class State(TypedDict):
 
 
 async def node(state: State) -> dict[str, str]:  # pyright: ignore[reportUnusedParameter]
+    # Wait (forever) until start_to_close_timeout or worker shutdown cancellation
     await asyncio.Event().wait()
     return {"value": "done"}