Class DelayedsExpr

dask/dataframe/dask_expr/_expr.py:3146–3182

class DelayedsExpr(Expr):
    def __str__(self):
        return f"{type(self).__name__}({self.operands[0]})"

    @functools.cached_property
    def _name(self):
        return f"delayed-container-{self.deterministic_token}"

    def _layer(self) -> dict:
        from dask.delayed import Delayed

        if isinstance(self.operands[0], TaskRef):
            tasks = [
                Alias((self._name, ix), fut.key) for ix, fut in enumerate(self.operands)
            ]
            dsk = {t.key: t for t in tasks}
        elif isinstance(self.operands[0], Delayed):
            expr = collections_to_expr(self.operands).optimize()
            keys = expr.__dask_keys__()
            dsk = expr.__dask_graph__()
            # Many APIs in dask-expr are not honoring __dask_keys__ but are instead
            # assuming they can just construct the keys themselves by walking the
            # partitions. Therefore we'll have to remap the key names and can't just
            # expose __dask_keys__()
            for ix, actual_key in enumerate(keys):
                dsk[(self._name, ix)] = Alias((self._name, ix), actual_key[0])
        else:
            raise TypeError("Expected a Delayed or Future object")

        return dsk

    def _divisions(self):
        return (None,) * (len(self.operands) + 1)

    @property
    def ndim(self):
        return 0


def is_broadcastable(dfs, s):