MCPcopy
hub / github.com/dask/dask / simplify

Method simplify

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

Source from the content-addressed store, hash-verified

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