Skip to content

Commit

Permalink
fixes deps
Browse files Browse the repository at this point in the history
  • Loading branch information
rudolfix committed Dec 29, 2024
1 parent 81f2293 commit 213fe68
Show file tree
Hide file tree
Showing 4 changed files with 417 additions and 696 deletions.
24 changes: 12 additions & 12 deletions .github/workflows/test_common.yml
Original file line number Diff line number Diff line change
Expand Up @@ -133,7 +133,7 @@ jobs:
shell: cmd
- name: Install pipeline and sources dependencies
run: poetry install --no-interaction -E duckdb -E cli -E parquet -E deltalake -E sql_database --with sentry-sdk,pipeline,sources && poetry run pip install pyarrow==15.0.2
run: poetry install --no-interaction -E duckdb -E cli -E parquet -E deltalake -E sql_database --with sentry-sdk,pipeline,sources # && poetry run pip install pyarrow==15.0.2

- run: |
poetry run pytest tests/extract tests/pipeline tests/libs tests/cli/common tests/destinations tests/sources
Expand All @@ -160,18 +160,18 @@ jobs:
shell: cmd
# here we upgrade pyarrow to 17 and run the libs tests again
- name: Install pyarrow 17
run: poetry run pip install pyarrow==17.0.0
# - name: Install pyarrow 17
# run: poetry run pip install pyarrow==17.0.0

- run: |
poetry run pytest tests/libs
if: runner.os != 'Windows'
name: Run libs tests Linux/MAC
- run: |
poetry run pytest tests/libs
if: runner.os == 'Windows'
name: Run libs tests Windows
shell: cmd
# - run: |
# poetry run pytest tests/libs
# if: runner.os != 'Windows'
# name: Run libs tests Linux/MAC
# - run: |
# poetry run pytest tests/libs
# if: runner.os == 'Windows'
# name: Run libs tests Windows
# shell: cmd

# - name: Install Pydantic 1.0
# run: pip install "pydantic<2"
Expand Down
2 changes: 1 addition & 1 deletion dlt/common/libs/pyarrow.py
Original file line number Diff line number Diff line change
Expand Up @@ -609,7 +609,7 @@ def row_tuples_to_arrow(
logger.info(
"Pandas not installed, reverting to numpy.asarray to create a table which is slower"
)
pivoted_rows = np.asarray(rows, dtype="object", order="k").T # type: ignore[call-overload]
pivoted_rows = np.asarray(rows, dtype="object", order="k").T

columnar = {
col: dat.ravel() for col, dat in zip(columns, np.vsplit(pivoted_rows, len(pivoted_rows)))
Expand Down
Loading

0 comments on commit 213fe68

Please sign in to comment.