add version to DeltaTableResource

dagster-io · Jan 20, 2024 · 7fa6bcd · 7fa6bcd
1 parent 4302375
commit 7fa6bcd
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/python_modules/libraries/dagster-deltalake/dagster_deltalake/resource.py b/python_modules/libraries/dagster-deltalake/dagster_deltalake/resource.py
@@ -42,9 +42,11 @@ def my_table(delta_table: DeltaTableResource):
         default=None, description="Additional configuration passed to http client."
     )
 
+    version: Optional[int]
+
     def load(self) -> DeltaTable:
         storage_options = self.storage_options.dict() if self.storage_options else {}
         client_options = self.client_options.dict() if self.client_options else {}
         options = {**storage_options, **client_options}
-        table = DeltaTable(table_uri=self.url, storage_options=options)
+        table = DeltaTable(table_uri=self.url, storage_options=options, version=self.version)
         return table