Method _broadcast_dep

dask/dataframe/dask_expr/_expr.py:3822–3824

(self, dep: Expr)

        return self.exprs[0]._divisions()

    def _broadcast_dep(self, dep: Expr):
        # Always broadcast single-partition dependencies in Fused
        return dep.npartitions == 1

    def _task(self, name: Key, index: int) -> Task:
        internal_tasks = []