Skip to content

Commit

Permalink
standardises dependency versions (#9)
Browse files Browse the repository at this point in the history
  • Loading branch information
rajagurunath committed May 26, 2023
1 parent 59905e0 commit cd731a9
Show file tree
Hide file tree
Showing 3 changed files with 12 additions and 8 deletions.
7 changes: 5 additions & 2 deletions dask_deltatable/core.py
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,6 @@
import dask
import dask.dataframe as dd
import pyarrow.parquet as pq
from boto3 import Session
from dask.base import tokenize
from dask.dataframe.io import from_delayed
from dask.delayed import delayed
Expand Down Expand Up @@ -171,7 +170,8 @@ def read_delta_table(self, **kwargs) -> dd.core.DataFrame:
for f in list(pq_files)
]
meta = self._make_meta_from_schema()
return from_delayed(parts, meta=meta)
verify_meta = kwargs.get("verify_meta", False)
return from_delayed(parts, meta=meta, verify_meta=verify_meta)


def _read_from_catalog(
Expand All @@ -180,6 +180,9 @@ def _read_from_catalog(
if ("AWS_ACCESS_KEY_ID" not in os.environ) and (
"AWS_SECRET_ACCESS_KEY" not in os.environ
):
# defer's installing boto3 upfront !
from boto3 import Session

session = Session()
credentials = session.get_credentials()
current_credentials = credentials.get_frozen_credentials()
Expand Down
8 changes: 3 additions & 5 deletions requirements.txt
Original file line number Diff line number Diff line change
@@ -1,6 +1,4 @@
dask[dataframe,distribuited]
boto3
deltalake==0.6.3
fsspec==2022.10.0
pyarrow==10.0.0
s3fs==2022.10.0
deltalake
fsspec
pyarrow
5 changes: 4 additions & 1 deletion setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,10 @@
long_description_content_type="text/markdown",
python_requires=">=3.7",
install_requires=open("requirements.txt").read().strip().split("\n"),
extras_require={"dev": ["pytest", "requests", "pytest-cov>=2.10.1"]},
extras_require={
"dev": ["pytest", "requests", "pytest-cov>=2.10.1"],
"s3": ["s3fs", "boto3"],
},
package_data={"dask_deltatable": ["*.pyi" "__init__.pyi", "core.pyi"]},
include_package_data=True,
zip_safe=False,
Expand Down

0 comments on commit cd731a9

Please sign in to comment.