Skip to content

Commit e4db5bc

Browse files
committed
chore: Force pyiceberg reader for polars iceberg scan
After the upgrade to 1.4 there have been persistent issues with Dagster runs hanging open. The 1.4 release introduced the polars native Iceberg reader which seems to be the culprit. This forces use of pyiceberg as the reader in an effort to address the problem.
1 parent ffaba2d commit e4db5bc

1 file changed

Lines changed: 3 additions & 1 deletion

File tree

packages/ol-orchestrate-lib/src/ol_orchestrate/lib/glue_helper.py

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,4 +128,6 @@ def get_dbt_model_as_dataframe(database_name: str, table_name: str) -> pl.LazyFr
128128
)
129129
table = glue.load_table(f"{database_name}.{table_name}")
130130

131-
return pl.scan_iceberg(table, storage_options=polars_s3_storage_options)
131+
return pl.scan_iceberg(
132+
table, reader_override="pyiceberg", storage_options=polars_s3_storage_options
133+
)

0 commit comments

Comments
 (0)