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

Method simplify

dask/_expr.py:445–460  ·  view source on GitHub ↗
(self)

Source from the content-addressed store, hash-verified

443 return self
444
445 def simplify(self) -> Expr:
446 expr = self
447 seen = set()
448 while True:
449 dependents = collect_dependents(expr)
450 new = expr.simplify_once(dependents=dependents, simplified={})
451 if new._name == expr._name:
452 break
453 if new._name in seen:
454 raise RuntimeError(
455 f"Optimizer does not converge. {expr!r} simplified to {new!r} which was already seen. "
456 "Please report this issue on the dask issue tracker with a minimal reproducer."
457 )
458 seen.add(new._name)
459 expr = new
460 return expr
461
462 def _simplify_down(self):
463 return

Callers 1

optimize_untilFunction · 0.45

Calls 4

setClass · 0.85
collect_dependentsFunction · 0.85
simplify_onceMethod · 0.80
addMethod · 0.45

Tested by

no test coverage detected