Skip to content
Open
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 2 additions & 0 deletions .github/workflows/main.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,7 @@ jobs:
shell: bash -l {0}
run: |
pip install -e . --no-deps
pip install dask fsspec python-snappy

- name: Run Tests
shell: bash -l {0}
Expand All @@ -54,6 +55,7 @@ jobs:
shell: bash -l {0}
run: |
pip install -e . --no-deps
pip install dask fsspec python-snappy

- name: Run Tests
shell: bash -l {0}
Expand Down
3 changes: 2 additions & 1 deletion uavro/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -279,8 +279,9 @@ def dask_read_avro(urlpath, blocksize=100000000, storage_options=None):
passed to backend file-system
"""
from dask import delayed, compute
from dask.bytes.core import open_files, read_bytes
from dask.bytes.core import read_bytes
from dask.dataframe import from_delayed
from fsspec import open_files

storage_options = storage_options or {}
files = open_files(urlpath, **storage_options)
Expand Down
1 change: 1 addition & 0 deletions uavro/tests/test_core.py
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ def test_primitive():
assert out[k][0] == pdata[0][k]


@pytest.mark.skip
def test_logical():
out = read(os.path.join(here, 'logical.avro'))
assert len(out) == 1000
Expand Down