Skip to content

Commit

Permalink
fix: large dtypes deprecated in private function (#18)
Browse files Browse the repository at this point in the history
  • Loading branch information
ion-elgreco authored Jan 28, 2025
1 parent 55f6245 commit 52102d9
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 5 deletions.
2 changes: 1 addition & 1 deletion libraries/dagster-delta-polars/pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[project]
name = "dagster-delta-polars"
version = "0.2.0"
version = "0.2.1"
description = "Polars deltalake IO Managers for Dagster with optional LakeFS support"
readme = "README.md"
requires-python = ">=3.9"
Expand Down
4 changes: 2 additions & 2 deletions libraries/dagster-delta/dagster_delta/handler.py
Original file line number Diff line number Diff line change
Expand Up @@ -238,7 +238,7 @@ def handle_output(
elif main_save_mode == "create_or_replace":
DeltaTable.create(
table_uri=connection.table_uri,
schema=_convert_pa_schema_to_delta(data.schema, **delta_params),
schema=_convert_pa_schema_to_delta(data.schema),
mode="overwrite",
partition_by=partition_columns,
configuration=table_config,
Expand All @@ -256,7 +256,7 @@ def handle_output(
logger.debug("Creating a DeltaTable first before merging.")
dt = DeltaTable.create(
table_uri=connection.table_uri,
schema=_convert_pa_schema_to_delta(data.schema, **delta_params),
schema=_convert_pa_schema_to_delta(data.schema),
partition_by=partition_columns,
configuration=table_config,
storage_options=connection.storage_options,
Expand Down
2 changes: 1 addition & 1 deletion libraries/dagster-delta/pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[project]
name = "dagster-delta"
version = "0.2.0"
version = "0.2.1"
description = "base deltalake IO Managers for Dagster"
readme = "README.md"
requires-python = ">=3.9"
Expand Down
2 changes: 1 addition & 1 deletion libraries/dagster-unity-catalog-polars/pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[project]
name = "dagster-unity-catalog-polars"
version = "0.2.0"
version = "0.2.1"
description = "Polars Unity Catalog IO Managers for Dagster"
readme = "README.md"
requires-python = ">=3.9"
Expand Down

0 comments on commit 52102d9

Please sign in to comment.