Skip to content

Commit

Permalink
renamed directory and corresponding imports
Browse files Browse the repository at this point in the history
  • Loading branch information
izzye84 committed Sep 24, 2024
1 parent ae23d3f commit 9f5e64b
Show file tree
Hide file tree
Showing 5 changed files with 11 additions and 11 deletions.
2 changes: 1 addition & 1 deletion hooli-data-ingest/hooli_data_ingest/__init__.py
Original file line number Diff line number Diff line change
@@ -1 +1 @@
from hooli_demo_assets.definitions import defs as defs
from hooli_data_ingest.definitions import defs as defs
2 changes: 1 addition & 1 deletion hooli-data-ingest/hooli_data_ingest/assets/sling.py
Original file line number Diff line number Diff line change
Expand Up @@ -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):
Expand Down
10 changes: 5 additions & 5 deletions hooli-data-ingest/hooli_data_ingest/definitions.py
Original file line number Diff line number Diff line change
Expand Up @@ -8,18 +8,18 @@
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(
assets=link_code_references_to_git_if_cloud(
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],
Expand Down
6 changes: 3 additions & 3 deletions hooli-data-ingest/hooli_data_ingest/resources/__init__.py
Original file line number Diff line number Diff line change
Expand Up @@ -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":
Expand Down
2 changes: 1 addition & 1 deletion hooli-data-ingest/hooli_data_ingest/schedules/__init__.py
Original file line number Diff line number Diff line change
@@ -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(
Expand Down

0 comments on commit 9f5e64b

Please sign in to comment.