Update sling import in dagster-components

dagster-io · Jan 13, 2025 · a76273f · a76273f
1 parent f9b0e32
commit a76273f
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/python_modules/libraries/dagster-components/dagster_components/lib/__init__.py b/python_modules/libraries/dagster-components/dagster_components/lib/__init__.py
@@ -1,14 +1,14 @@
 import importlib.util
 
 _has_dagster_dbt = importlib.util.find_spec("dagster_dbt") is not None
-_has_dagster_embedded_elt = importlib.util.find_spec("dagster_embedded_elt") is not None
+_has_dagster_sling = importlib.util.find_spec("dagster_sling") is not None
 
 if _has_dagster_dbt:
     from dagster_components.lib.dbt_project.component import (
         DbtProjectComponent as DbtProjectComponent,
     )
 
-if _has_dagster_embedded_elt:
+if _has_dagster_sling:
     from dagster_components.lib.sling_replication_collection.component import (
         SlingReplicationCollectionComponent as SlingReplicationCollectionComponent,
     )

diff --git a/...aries/dagster-components/dagster_components/lib/sling_replication_collection/component.py b/...aries/dagster-components/dagster_components/lib/sling_replication_collection/component.py
@@ -6,8 +6,8 @@
 from dagster._core.definitions.definitions_class import Definitions
 from dagster._core.definitions.events import AssetMaterialization
 from dagster._core.definitions.result import MaterializeResult
-from dagster_embedded_elt.sling import DagsterSlingTranslator, SlingResource, sling_assets
-from dagster_embedded_elt.sling.resources import AssetExecutionContext
+from dagster_sling import DagsterSlingTranslator, SlingResource, sling_assets
+from dagster_sling.resources import AssetExecutionContext
 from pydantic import BaseModel
 from typing_extensions import Self
 

diff --git a/...custom_sling_location/custom_sling_location/components/debug_sling_component/component.py b/...custom_sling_location/custom_sling_location/components/debug_sling_component/component.py
@@ -5,7 +5,7 @@
 from dagster_components.lib.sling_replication_collection.component import (
     SlingReplicationCollectionComponent,
 )
-from dagster_embedded_elt.sling import SlingResource
+from dagster_sling import SlingResource
 
 
 @component_type(name="debug_sling_replication")

diff --git a/...ster-components/dagster_components_tests/integration_tests/test_sling_integration_test.py b/...ster-components/dagster_components_tests/integration_tests/test_sling_integration_test.py
@@ -21,7 +21,7 @@
 from dagster_components.lib.sling_replication_collection.component import (
     SlingReplicationCollectionComponent,
 )
-from dagster_embedded_elt.sling import SlingResource
+from dagster_sling import SlingResource
 
 from dagster_components_tests.utils import assert_assets, get_asset_keys, script_load_context