feat: dbt asset ignore conditions

TEAMSchools · Jan 28, 2025 · ec0e01c · ec0e01c
1 parent 58f0dbb
commit ec0e01c
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 2 deletions.
diff --git a/src/dbt/kipptaf/models/people/properties.yml b/src/dbt/kipptaf/models/people/properties.yml
@@ -7,3 +7,17 @@ models:
         data_tests:
           - unique
           - not_null
+  - name: base_people__staff_roster_history
+    meta:
+      dagster:
+        automation_condition:
+          ignore:
+            keys:
+              - kipptaf/surveys/int_surveys__staff_information_survey_pivot
+  - name: int_people__staff_roster_history
+    meta:
+      dagster:
+        automation_condition:
+          ignore:
+            keys:
+              - kipptaf/surveys/int_surveys__staff_information_survey_pivot
diff --git a/src/teamster/libraries/dbt/dagster_dbt_translator.py b/src/teamster/libraries/dbt/dagster_dbt_translator.py
@@ -1,6 +1,6 @@
 from typing import Any, Mapping
 
-from dagster import AssetKey, AutomationCondition
+from dagster import AssetKey, AssetSelection, AutomationCondition
 from dagster_dbt import DagsterDbtTranslator, DagsterDbtTranslatorSettings
 
 
@@ -46,7 +46,12 @@ def get_automation_condition(
             )
         else:
             return (
-                AutomationCondition.eager() | AutomationCondition.code_version_changed()
+                AutomationCondition.eager().ignore(
+                    AssetSelection.keys(
+                        *automation_condition_config.get("ignore", {}).get("keys", {})
+                    )
+                )
+                | AutomationCondition.code_version_changed()
             )
 
     def get_group_name(self, dbt_resource_props: Mapping[str, Any]) -> str | None: