Function _is_dask_future

dask/_task_spec.py:369–375

Check if obj is a dask Future (TaskRef or duck-typed with __dask_future__). This supports both distributed.Future (which inherits from TaskRef) and third-party scheduler futures that set __dask_future__ = True.

(obj: object)

def _is_dask_future(obj: object) -> bool:
    """Check if obj is a dask Future (TaskRef or duck-typed with __dask_future__).

    This supports both distributed.Future (which inherits from TaskRef) and
    third-party scheduler futures that set __dask_future__ = True.
    """
    return isinstance(obj, TaskRef) or getattr(obj, "__dask_future__", False)


class GraphNode: