diff --git a/dbt_project/models/CLEANED/orders_aggregated.sql b/dbt_project/models/CLEANED/orders_aggregated.sql deleted file mode 100644 index bbc25e66..00000000 --- a/dbt_project/models/CLEANED/orders_aggregated.sql +++ /dev/null @@ -1 +0,0 @@ -select * from {{ ref("orders_cleaned") }} \ No newline at end of file diff --git a/dbt_project/models/CLEANED/orders_cleaned.sql b/dbt_project/models/CLEANED/orders_cleaned.sql index 7b7f8d95..c200e626 100644 --- a/dbt_project/models/CLEANED/orders_cleaned.sql +++ b/dbt_project/models/CLEANED/orders_cleaned.sql @@ -5,7 +5,6 @@ select purchase_price, sku, dt, - dt as dt_2, cast(dt as datetime) as order_date, quantity * purchase_price as order_total from {{ source("raw_data", "orders") }} diff --git a/hooli-data-eng/src/hooli_data_eng/defs/dbt/component.yaml b/hooli-data-eng/src/hooli_data_eng/defs/dbt/component.yaml index c3b13976..f8977600 100644 --- a/hooli-data-eng/src/hooli_data_eng/defs/dbt/component.yaml +++ b/hooli-data-eng/src/hooli_data_eng/defs/dbt/component.yaml @@ -2,7 +2,7 @@ type: hooli_data_eng.defs.dbt.component.HooliDbtComponent attributes: groups: - - selection: "company_stats locations_cleaned sku_stats company_perf orders_aggregated" + - selection: "company_stats locations_cleaned sku_stats company_perf" run_on_code_version_change: true - selection: "weekly_order_summary order_stats" diff --git a/scripts/get_changed_assets.py b/scripts/get_changed_assets.py index bde079d5..6289c9b2 100644 --- a/scripts/get_changed_assets.py +++ b/scripts/get_changed_assets.py @@ -159,11 +159,10 @@ def format_commands( ) -> str: lines = [] for (location, repository), asset_keys in sorted(grouped.items()): - asset_args = " ".join(f"--asset-key {key}" for key in asset_keys) + asset_args = " ".join(f"--asset-key 'key:\"{key}\"'" for key in asset_keys) lines.append( f"dagster-cloud job launch" f" --location {location}" - f" --repository {repository}" f" --job {job}" f" {asset_args}" )