Class CompositeExpr

dask/_expr.py:1280–1309

Private expression grouping many child expressions into one collection.

class CompositeExpr(Expr):
    """Private expression grouping many child expressions into one collection."""

    _parameters = ["collection"]

    @property
    def collection(self):
        return self.operand("collection")

    @property
    def exprs(self):
        return tuple(self.operands[1:])

    def dependencies(self):
        return self.exprs

    def _layer(self) -> dict:
        return {}

    def __dask_keys__(self) -> list:
        return [expr.__dask_keys__() for expr in self.exprs]

    def _operands_for_repr(self):
        return [
            f"collection={type(self.collection).__name__}",
            f"nexprs={len(self.exprs)}",
        ]

    def finalize_compute(self):
        return CompositeFinalizeCompute(self.collection, *self.exprs)


class _AnnotationsTombstone: ...