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

Function collect_dependents

dask/_expr.py:887–900  ·  view source on GitHub ↗
(expr)

Source from the content-addressed store, hash-verified

885
886
887def collect_dependents(expr) -> defaultdict:
888 dependents = defaultdict(list)
889 stack = [expr]
890 seen = set()
891 while stack:
892 node = stack.pop()
893 if node._name in seen:
894 continue
895 seen.add(node._name)
896
897 for dep in node.dependencies():
898 stack.append(dep)
899 dependents[dep._name].append(weakref.ref(node))
900 return dependents
901
902
903def optimize(expr: Expr, fuse: bool = True) -> Expr:

Callers 1

simplifyMethod · 0.85

Calls 5

setClass · 0.85
popMethod · 0.80
refMethod · 0.80
addMethod · 0.45
dependenciesMethod · 0.45

Tested by

no test coverage detected