Method _layer

dask/_expr.py:1394–1404

(self)

        return [self._name]

    def _layer(self) -> dict:
        func, extra_args = self.collection.__dask_postcompute__()
        keys = [expr.__dask_keys__() for expr in self.exprs]
        return {
            self._name: Task(
                self._name,
                func,
                _convert_dask_keys(keys),
                *extra_args,
            )
        }


class ProhibitReuse(Expr):