MCPcopy
hub / github.com/dask/dask / get_all_dependencies

Method get_all_dependencies

dask/highlevelgraph.py:609–626  ·  view source on GitHub ↗

Get dependencies of all keys This will in most cases materialize all layers, which makes it an expensive operation. Returns ------- map: Mapping A map that maps each key to its dependencies

(self)

Source from the content-addressed store, hash-verified

607 return self.to_dict().values()
608
609 def get_all_dependencies(self) -> dict[Key, set[Key]]:
610 """Get dependencies of all keys
611
612 This will in most cases materialize all layers, which makes
613 it an expensive operation.
614
615 Returns
616 -------
617 map: Mapping
618 A map that maps each key to its dependencies
619 """
620 all_keys = self.keys()
621 missing_keys = all_keys - self.key_dependencies.keys()
622 if missing_keys:
623 for layer in self.layers.values():
624 for k in missing_keys & layer.keys():
625 self.key_dependencies[k] = layer.get_dependencies(k, all_keys)
626 return self.key_dependencies
627
628 @property
629 def dependents(self) -> dict[str, set[str]]:

Callers 2

test_copyFunction · 0.95
__dask_keys__Method · 0.80

Calls 3

keysMethod · 0.95
get_dependenciesMethod · 0.80
valuesMethod · 0.45

Tested by 1

test_copyFunction · 0.76