Trigger org-fixes directly, remove org er dag

Part of georgetown-cset/cset_article_schema#164
georgetown-cset · Apr 10, 2024 · 6d8e43b · 6d8e43b
1 parent a743d50
commit 6d8e43b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 46 deletions.
diff --git a/linkage_dag.py b/linkage_dag.py
@@ -571,9 +571,9 @@
     ) as f:
         table_desc = json.loads(f.read())
 
-    trigger_org_er_and_metadata_merge = TriggerDagRunOperator(
-        task_id="trigger_org_er_and_metadata_merge",
-        trigger_dag_id="org_er_and_metadata_merge",
+    trigger_org_fixes = TriggerDagRunOperator(
+        task_id="trigger_org_fixes",
+        trigger_dag_id="org_fixes",
     )
 
     for table in production_tables:
@@ -606,7 +606,7 @@
             >> snapshot
             >> pop_descriptions
             >> success_alert
-            >> trigger_org_er_and_metadata_merge
+            >> trigger_org_fixes
         )
 
     # We don't show the "all metadata" table in the production dataset, but we do need to

diff --git a/metadata_merge_trigger.py b/metadata_merge_trigger.py