Update dagster-dlt package

Author: richban

opendata_stack_platform_project/opendata_stack_platform/definitions.py

@@ -7,7 +7,7 @@
     mem_io_manager,
 )
 from dagster_aws.s3 import S3Resource
-from dagster_embedded_elt.dlt import DagsterDltResource
+from dagster_dlt import DagsterDltResource
 
 from opendata_stack_platform import assets
 from opendata_stack_platform.dbt import assets as dbt_assets

opendata_stack_platform_project/opendata_stack_platform/dlt/assets.py

@@ -1,7 +1,7 @@
 from collections.abc import Iterable
 
 from dagster import AssetExecutionContext, AssetKey
-from dagster_embedded_elt.dlt import (
+from dagster_dlt import (
     DagsterDltResource,
     DagsterDltTranslator,
     dlt_assets,

opendata_stack_platform_project/opendata_stack_platform/utils/paths.py

@@ -1,12 +1,13 @@
 """Utility functions for handling paths in the project."""
 
 import os
+
 from pathlib import Path
 
 
 def get_project_root() -> Path:
     """Get the absolute path to the project root directory.
-    
+
     Returns:
         Path: Absolute path to the project root directory
     """
@@ -17,13 +18,13 @@ def get_project_root() -> Path:
 
 def get_duckdb_path() -> Path:
     """Get the absolute path to the DuckDB database file.
-    
+
     Returns:
         Path: Absolute path to the DuckDB database file
     """
     # First try environment variable
     if db_path := os.getenv("DUCKDB_DATABASE"):
         return Path(db_path)
-    
+
     # Default to data/nyc_database.duckdb in project root
     return get_project_root() / "data" / "nyc_database.duckdb"

requirements.txt

@@ -1,7 +1,7 @@
 polars==1.22.0
 dagster==1.10.1
 dagster-webserver==1.10.1
-dagster-embedded-elt==0.26.1
+dagster-dlt==0.26.1
 dagster-polars==0.26.1
 dagster-aws==0.26.1
 dagster-duckdb==0.26.1