Function test_open_files_write

dask/bytes/tests/test_s3.py:245–253

(s3, s3so)

def test_open_files_write(s3, s3so):
    paths = [f"s3://{test_bucket_name}/more/{f}" for f in files]
    fils = open_files(paths, mode="wb", **s3so)
    for fil, data in zip(fils, files.values()):
        with fil as f:
            f.write(data)
    sample, values = read_bytes(f"s3://{test_bucket_name}/more/test/accounts.*", **s3so)
    results = compute(*concat(values))
    assert set(files.values()) == set(results)


def test_read_bytes(s3, s3so):