[dagster-deltalake] Fix GcsConfig() ImportError and TypeError for par…

…titioned assets (#22054) ## Summary & Motivation Closes [[dagster-deltalake] GcsConfig ImportError and TypeError for partitioned assets #22053](#22053) ## How I Tested These Changes `python -m pytest python_modules/libraries/dagster-deltalake/dagster_deltalake_tests`
dagster-io · Jun 3, 2024 · 8029bc5 · 8029bc5
1 parent 3e4af27
commit 8029bc5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/python_modules/libraries/dagster-deltalake/dagster_deltalake/__init__.py b/python_modules/libraries/dagster-deltalake/dagster_deltalake/__init__.py
@@ -5,6 +5,7 @@
 
 from .config import (
     AzureConfig as AzureConfig,
+    GcsConfig as GcsConfig,
     LocalConfig as LocalConfig,
     S3Config as S3Config,
 )

diff --git a/python_modules/libraries/dagster-deltalake/dagster_deltalake/handler.py b/python_modules/libraries/dagster-deltalake/dagster_deltalake/handler.py
@@ -260,6 +260,6 @@ def _table_reader(table_slice: TableSlice, connection: TableConnection) -> ds.Da
 
     dataset = table.to_pyarrow_dataset()
     if partition_expr is not None:
-        dataset = dataset.filter(expression=partition_expr)
+        dataset = dataset.filter(partition_expr)
 
     return dataset