fix: compatibility with dagster==1.11.1 (#34)

Author: gfvioli

libraries/dagster-delta/dagster_delta/_db_io_manager/custom_db_io_manager.py

@@ -5,10 +5,10 @@
     cast,
 )
 
-from dagster._core.definitions.multi_dimensional_partitions import (
+from dagster._core.definitions.partitions.definition.multi import (
     MultiPartitionsDefinition,
 )
-from dagster._core.definitions.time_window_partitions import (
+from dagster._core.definitions.partitions.definition.time_window import (
     TimeWindowPartitionsDefinition,
 )
 from dagster._core.execution.context.input import InputContext

libraries/dagster-delta/dagster_delta/_db_io_manager/utils.py

@@ -10,7 +10,7 @@
     MultiPartitionsDefinition,
     TimeWindowPartitionsDefinition,
 )
-from dagster._core.definitions.time_window_partitions import TimeWindow
+from dagster._core.definitions.partitions.utils import TimeWindow
 from dagster._core.storage.db_io_manager import TablePartitionDimension
 from pendulum import instance as pdi
 

libraries/dagster-delta/dagster_delta/_handler/utils/date_format.py

@@ -5,7 +5,7 @@
     MultiPartitionsDefinition,
     OutputContext,
 )
-from dagster._core.definitions.time_window_partitions import (
+from dagster._core.definitions.partitions.definition.time_window import (
     TimeWindowPartitionsDefinition,
 )
 

libraries/dagster-delta/dagster_delta/_handler/utils/dnf.py

@@ -1,7 +1,7 @@
 from collections.abc import Iterable, Sequence
 from typing import Optional, Union, cast
 
-from dagster._core.definitions.time_window_partitions import (
+from dagster._core.definitions.partitions.utils import (
     TimeWindow,
 )
 from dagster._core.storage.db_io_manager import TablePartitionDimension

libraries/dagster-delta/dagster_delta/io_manager/base.py

@@ -8,7 +8,7 @@
 
 from dagster import InputContext, OutputContext
 from dagster._config.pythonic_config import ConfigurableIOManagerFactory
-from dagster._core.definitions.time_window_partitions import TimeWindow
+from dagster._core.definitions.partitions.utils import TimeWindow
 from dagster._core.storage.db_io_manager import (
     DbClient,
     DbTypeHandler,

libraries/dagster-delta/pyproject.toml

@@ -1,29 +1,31 @@
 [project]
 name = "dagster-delta"
-version = "0.5.0"
+version = "0.5.1"
 description = "Deltalake IO Managers for Dagster with pyarrow and Polars support."
 readme = "README.md"
 requires-python = ">=3.9"
-dependencies = [
-    "dagster>=1.8,<2.0",
-    "deltalake>=1.0.0",
-    "pendulum>=3.0.0",
-]
-authors = [{name = "Ion Koutsouris"}]
+dependencies = ["dagster>=1.11.1,<2.0", "deltalake>=1.0.0", "pendulum>=3.0.0"]
+authors = [{ name = "Ion Koutsouris" }]
 license-files = ["LICENSE", "licenses/elementl LICENSE"]
 classifiers = [
     "License :: OSI Approved :: Apache Software License",
     "Programming Language :: Python :: 3.9",
     "Programming Language :: Python :: 3.10",
     "Programming Language :: Python :: 3.11",
-    "Programming Language :: Python :: 3.12"
+    "Programming Language :: Python :: 3.12",
+]
+keywords = [
+    "dagster",
+    "deltalake",
+    "delta",
+    "datalake",
+    "io manager",
+    "polars",
+    "pyarrow",
 ]
-keywords = ["dagster", "deltalake", "delta","datalake", "io manager", "polars", "pyarrow"]
 
 [project.optional-dependencies]
-polars = [
-    "polars>=1.31.0"
-]
+polars = ["polars>=1.31.0"]
 
 [build-system]
 requires = ["hatchling"]
@@ -32,7 +34,7 @@ build-backend = "hatchling.build"
 [tool.pyright]
 
 typeCheckingMode = 'basic'
-reportUnknownMemberType   = false
+reportUnknownMemberType = false
 exclude = [
     ".bzr",
     ".direnv",
@@ -59,7 +61,7 @@ exclude = [
 venvPath = "."
 venv = ".venv"
 reportMissingImports = false
-pythonVersion =  "3.10"
+pythonVersion = "3.10"
 
 [tool.ruff]