hub / github.com/dask/dask / assert_topological_sort

Function assert_topological_sort

dask/tests/test_order.py:2066–2072 · view source on GitHub ↗

(dsk, order)

Source from the content-addressed store, hash-verified

2064
2065
2066	def assert_topological_sort(dsk, order):
2067	dependencies, dependents = get_deps(dsk)
2068	num_needed = {k: len(dependencies[k]) for k in dsk}
2069	for k in sorted(dsk, key=order.__getitem__):
2070	assert num_needed[k] == 0
2071	for dep in dependents[k]:
2072	num_needed[dep] -= 1
2073
2074
2075	def test_doublediff(abcde):

test_ordering_keeps_groups_togetherFunction · 0.85

test_avoid_broker_nodesFunction · 0.85

test_base_of_reduce_preferredFunction · 0.85

test_avoid_upwards_branchingFunction · 0.85

test_avoid_upwards_branching_complexFunction · 0.85

test_deep_bases_win_over_dependentsFunction · 0.85

test_prefer_deepFunction · 0.85

test_break_ties_by_strFunction · 0.85

test_gh_3055Function · 0.85

test_favor_longest_critical_pathFunction · 0.85

test_run_smaller_sectionsFunction · 0.85

test_local_parents_of_reductionFunction · 0.85

get_depsFunction · 0.90

no test coverage detected

searching dependent graphs…