MCPcopy Create free account
hub / github.com/dask/dask / _broadcast_dep

Method _broadcast_dep

dask/dataframe/dask_expr/_expr.py:1876–1883  ·  view source on GitHub ↗
(self, dep: Expr)

Source from the content-addressed store, hash-verified

1874 return {}
1875
1876 def _broadcast_dep(self, dep: Expr):
1877 if (
1878 dep.npartitions == 1
1879 and isinstance(self.operand("arg"), Expr)
1880 and dep is self.operand("arg")
1881 ):
1882 return True
1883 return super()._broadcast_dep(dep)
1884
1885 def _divisions(self):
1886 if not self.is_monotonic:

Callers 4

_divisionsMethod · 0.95
_simplify_downMethod · 0.45
_fusion_passFunction · 0.45
_tune_upMethod · 0.45

Calls 1

operandMethod · 0.80

Tested by

no test coverage detected