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

Function test_tokenize_nested_sequence_thread_safe

dask/tests/test_tokenize.py:1498–1512  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1496
1497
1498def test_tokenize_nested_sequence_thread_safe():
1499 nested_list = []
1500 for ix in range(100):
1501 nested_list = [ix, nested_list]
1502
1503 nested_dict = {}
1504 for ix in range(50):
1505 nested_dict = {ix: nested_dict}
1506
1507 normalize_token(nested_list)
1508 with ThreadPoolExecutor() as pool:
1509 futures = [pool.submit(normalize_token, nested_list) for _ in range(1000)]
1510 assert len({f.result() for f in futures}) == 1
1511 futures = [pool.submit(normalize_token, nested_dict) for _ in range(1000)]
1512 assert len({f.result() for f in futures}) == 1
1513
1514
1515def test_tokenize_range_index():

Callers

nothing calls this directly

Calls 1

submitMethod · 0.45

Tested by

no test coverage detected