MCPcopy
hub / github.com/dask/dask / test_read_bytes

Function test_read_bytes

dask/bytes/tests/test_local.py:64–77  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

62
63
64def test_read_bytes():
65 with filetexts(files, mode="b"):
66 sample, values = read_bytes(".test.accounts.*")
67 assert isinstance(sample, bytes)
68 assert sample[:5] == files[sorted(files)[0]][:5]
69 assert sample.endswith(b"\n")
70
71 assert isinstance(values, (list, tuple))
72 assert isinstance(values[0], (list, tuple))
73 assert hasattr(values[0][0], "dask")
74
75 assert sum(map(len, values)) >= len(files)
76 results = compute(*concat(values))
77 assert set(results) == set(files.values())
78
79
80def test_read_bytes_sample_delimiter():

Callers

nothing calls this directly

Calls 7

filetextsFunction · 0.90
read_bytesFunction · 0.90
computeFunction · 0.90
setClass · 0.85
sumFunction · 0.50
concatFunction · 0.50
valuesMethod · 0.45

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…