Function assert_eq

dask/bag/utils.py:4–10 · view source on GitHub ↗

(a, b, scheduler="sync")

Source from the content-addressed store, hash-verified

2
3
4	def assert_eq(a, b, scheduler="sync"):
5	if hasattr(a, "compute"):
6	a = a.compute(scheduler=scheduler)
7	if hasattr(b, "compute"):
8	b = b.compute(scheduler=scheduler)
9
10	assert a == b

test_bag_mapFunction · 0.90

test_fold_bagFunction · 0.90

test_distinct_with_keyFunction · 0.90

test_frequenciesFunction · 0.90

test_aggregationFunction · 0.90

test_non_splittable_reductionsFunction · 0.90

test_stdFunction · 0.90

test_varFunction · 0.90

test_joinFunction · 0.90

test_map_partitions_args_kwargsFunction · 0.90

test_repartition_npartitionsFunction · 0.90

test_repartition_partition_sizeFunction · 0.90

computeMethod · 0.45

test_bag_mapFunction · 0.72

test_fold_bagFunction · 0.72

test_distinct_with_keyFunction · 0.72

test_frequenciesFunction · 0.72

test_aggregationFunction · 0.72

test_non_splittable_reductionsFunction · 0.72

test_stdFunction · 0.72

test_varFunction · 0.72

test_joinFunction · 0.72

test_map_partitions_args_kwargsFunction · 0.72

test_repartition_npartitionsFunction · 0.72

test_repartition_partition_sizeFunction · 0.72

searching dependent graphs…