diff --git a/hooli-data-ingest/hooli_data_ingest/__init__.py b/hooli-data-ingest/hooli_data_ingest/__init__.py index 59d0a1b..4be0ed3 100644 --- a/hooli-data-ingest/hooli_data_ingest/__init__.py +++ b/hooli-data-ingest/hooli_data_ingest/__init__.py @@ -1 +1 @@ -from hooli_demo_assets.definitions import defs as defs \ No newline at end of file +from hooli_data_ingest.definitions import defs as defs \ No newline at end of file diff --git a/hooli-data-ingest/hooli_data_ingest/assets/sling.py b/hooli-data-ingest/hooli_data_ingest/assets/sling.py index acd1d00..943a6d8 100644 --- a/hooli-data-ingest/hooli_data_ingest/assets/sling.py +++ b/hooli-data-ingest/hooli_data_ingest/assets/sling.py @@ -5,7 +5,7 @@ ) from dagster_embedded_elt.sling.dagster_sling_translator import DagsterSlingTranslator -from hooli_demo_assets.resources import replication_config +from hooli_data_ingest.resources import replication_config class CustomSlingTranslator(DagsterSlingTranslator): diff --git a/hooli-data-ingest/hooli_data_ingest/definitions.py b/hooli-data-ingest/hooli_data_ingest/definitions.py index 32c2360..def2e3e 100644 --- a/hooli-data-ingest/hooli_data_ingest/definitions.py +++ b/hooli-data-ingest/hooli_data_ingest/definitions.py @@ -8,10 +8,10 @@ from dagster._core.definitions.metadata import with_source_code_references from dagster_cloud.metadata.source_code import link_code_references_to_git_if_cloud -from hooli_demo_assets.assets.sling import my_sling_assets -from hooli_demo_assets.jobs import daily_sling_job -from hooli_demo_assets.resources import sling_resource -from hooli_demo_assets.schedules import daily_sling_assets +from hooli_data_ingest.assets.sling import my_sling_assets +from hooli_data_ingest.jobs import daily_sling_job +from hooli_data_ingest.resources import sling_resource +from hooli_data_ingest.schedules import daily_sling_assets defs = Definitions( @@ -19,7 +19,7 @@ with_source_code_references([my_sling_assets]), file_path_mapping=AnchorBasedFilePathMapping( local_file_anchor=Path(__file__), - file_anchor_path_in_repository="hooli-demo-assets/hooli_demo_assets/definitions.py", + file_anchor_path_in_repository="hooli-data-ingest/hooli_data_ingest/definitions.py", ), ), schedules=[daily_sling_assets], diff --git a/hooli-data-ingest/hooli_data_ingest/resources/__init__.py b/hooli-data-ingest/hooli_data_ingest/resources/__init__.py index 187fd4b..d8f33b8 100644 --- a/hooli-data-ingest/hooli_data_ingest/resources/__init__.py +++ b/hooli-data-ingest/hooli_data_ingest/resources/__init__.py @@ -16,10 +16,10 @@ def get_env(): # Paths for local dev current_file_path = Path(__file__) -hooli_demo_root = current_file_path.parent.parent.parent -project_root = hooli_demo_root.parent +hooli_data_ingest_root = current_file_path.parent.parent.parent +project_root = hooli_data_ingest_root.parent DUCKDB_PATH = project_root / "dbt_project" / "example.duckdb" -LOCATIONS_CSV_PATH = f"file://{hooli_demo_root}/locations.csv" +LOCATIONS_CSV_PATH = f"file://{hooli_data_ingest_root}/locations.csv" if get_env() == "LOCAL": diff --git a/hooli-data-ingest/hooli_data_ingest/schedules/__init__.py b/hooli-data-ingest/hooli_data_ingest/schedules/__init__.py index 9554a18..8a79746 100644 --- a/hooli-data-ingest/hooli_data_ingest/schedules/__init__.py +++ b/hooli-data-ingest/hooli_data_ingest/schedules/__init__.py @@ -1,5 +1,5 @@ from dagster import ScheduleDefinition -from hooli_demo_assets.jobs import daily_sling_job +from hooli_data_ingest.jobs import daily_sling_job daily_sling_assets = ScheduleDefinition(