Add backwards compat aliasing

distributed/__init__.py

@@ -20,10 +20,17 @@
 from dask.config import config  # type: ignore
 
 from distributed._version import get_versions
-from distributed.actor import Actor, ActorTask, BaseActorTask
+from distributed.actor import (
+    Actor,
+    ActorFuture,
+    ActorTask,
+    BaseActorFuture,
+    BaseActorTask,
+)
 from distributed.client import (
     Client,
     CompatibleExecutor,
+    Future,
     Task,
     as_completed,
     default_client,
@@ -32,6 +39,7 @@
     get_task_metadata,
     get_task_stream,
     performance_report,
+    tasks_of,
     wait,
 )
 from distributed.core import Status, connect, rpc
@@ -121,14 +129,17 @@ def _():
 __all__ = [
     "Actor",
     "ActorTask",
+    "ActorFuture",
     "Adaptive",
     "BaseActorTask",
+    "BaseActorFuture",
     "CancelledError",
     "Client",
     "CompatibleExecutor",
     "CondaInstall",
     "Environ",
     "Event",
+    "Future",
     "Task",
     "KilledWorker",
     "LocalCluster",
@@ -163,6 +174,7 @@ def _():
     "default_client",
     "fire_and_forget",
     "futures_of",
+    "tasks_of",
     "get_client",
     "get_task_metadata",
     "get_task_stream",

distributed/actor.py

@@ -256,6 +256,9 @@ def __repr__(self) -> Literal["<ActorTask>"]:
         return "<ActorTask>"
 
 
+BaseActorFuture = BaseActorTask
+
+
 @dataclass(frozen=True, eq=False)
 class EagerActorTask(BaseActorTask[_T]):
     """Task to an actor's method call when an actor calls another actor on the same worker"""
@@ -313,3 +316,6 @@ def _set_result(self, out: _Error | _OK[_T]) -> None:
 
     def result(self, timeout: str | timedelta | float | None = None) -> _T:
         return sync(self._io_loop, self._result, callback_timeout=timeout)
+
+
+ActorFuture = ActorTask

distributed/client.py

@@ -531,6 +531,9 @@ def __await__(self):
         return self.result().__await__()
 
 
+Future = Task
+
+
 class TaskState:
     """A Task's internal state.
 
@@ -4671,6 +4674,16 @@ async def _get_versions(
 
         return result
 
+    def tasks_of(self, tasks):
+        """Wrapper method of futures_of
+
+        Parameters
+        ----------
+        tasks : tuple
+            The tasks
+        """
+        return tasks_of(tasks, client=self)
+
     def futures_of(self, tasks):
         """Wrapper method of futures_of
 
@@ -4679,7 +4692,7 @@ def futures_of(self, tasks):
         tasks : tuple
             The tasks
         """
-        return futures_of(tasks, client=self)
+        return tasks_of(tasks, client=self)
 
     @classmethod
     def _expand_key(cls, k):
@@ -5825,7 +5838,7 @@ def redict_collection(c, dsk):
         return cc
 
 
-def futures_of(o, client=None):
+def tasks_of(o, client=None):
     """Task objects in a collection
 
     Parameters
@@ -5877,6 +5890,9 @@ def futures_of(o, client=None):
     return tasks[::-1]
 
 
+futures_of = tasks_of
+
+
 def fire_and_forget(obj):
     """Run tasks at least once, even if we release the tasks