Rename gather => all, and make gather an alias

Author: chriso

src/dispatch/__init__.py

@@ -3,7 +3,7 @@
 from __future__ import annotations
 
 import dispatch.integrations
-from dispatch.coroutine import call, gather
+from dispatch.coroutine import all, call, gather
 from dispatch.function import DEFAULT_API_URL, Client
 from dispatch.id import DispatchID
 from dispatch.proto import Call, Error, Input, Output
@@ -20,4 +20,5 @@
     "Status",
     "call",
     "gather",
+    "all",
 ]

src/dispatch/coroutine.py

@@ -17,12 +17,19 @@ def call(call: Call) -> Any:
 @coroutine
 @durable
 def gather(*awaitables: Awaitable[Any]) -> list[Any]:  # type: ignore[misc]
+    """Alias for all."""
+    return all(*awaitables)
+
+
+@coroutine
+@durable
+def all(*awaitables: Awaitable[Any]) -> list[Any]:  # type: ignore[misc]
     """Concurrently run a set of coroutines and block until all
     results are available. If any coroutine fails with an uncaught
     exception, it will be re-raised when awaiting a result here."""
-    return (yield Gather(awaitables))
+    return (yield All(awaitables))
 
 
 @dataclass(slots=True)
-class Gather:
+class All:
     awaitables: tuple[Awaitable[Any], ...]

src/dispatch/scheduler.py

@@ -4,7 +4,7 @@
 from dataclasses import dataclass
 from typing import Any, Callable, Protocol, TypeAlias
 
-from dispatch.coroutine import Gather
+from dispatch.coroutine import All
 from dispatch.error import IncompatibleStateError
 from dispatch.experimental.durable.function import DurableCoroutine, DurableGenerator
 from dispatch.proto import Call, Error, Input, Output
@@ -78,8 +78,8 @@ def value(self) -> Any:
 
 
 @dataclass(slots=True)
-class GatherFuture:
-    """A future result of a dispatch.coroutine.gather() operation."""
+class AllFuture:
+    """A future result of a dispatch.coroutine.all() operation."""
 
     order: list[CoroutineID]
     waiting: set[CoroutineID]
@@ -386,11 +386,9 @@ def _run(self, input: Input) -> Output:
                     state.prev_callers.append(coroutine)
                     state.outstanding_calls += 1
 
-                case Gather():
-                    gather = coroutine_yield
-
+                case All():
                     children = []
-                    for awaitable in gather.awaitables:
+                    for awaitable in coroutine_yield.awaitables:
                         g = awaitable.__await__()
                         if not isinstance(g, DurableGenerator):
                             raise ValueError(
@@ -408,7 +406,7 @@ def _run(self, input: Input) -> Output:
                     state.ready = children + state.ready
 
                     child_ids = [child.id for child in children]
-                    coroutine.result = GatherFuture(
+                    coroutine.result = AllFuture(
                         order=child_ids, waiting=set(child_ids), results={}
                     )
                     state.suspended[coroutine.id] = coroutine