DAGs: Bad logic

hubmapconsortium · Mar 6, 2024 · 0d0c217 · 0d0c217
1 parent f64ec0d
commit 0d0c217
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/ingest-pipeline/airflow/dags/rebuild_multiple_metadata.py b/src/ingest-pipeline/airflow/dags/rebuild_multiple_metadata.py
@@ -65,12 +65,12 @@ def build_dataset_lists(**kwargs):
                 if ds_rslt.get("dataset_info"):
                     # dataset_info should only be populated for processed_datasets
                     print(ds_rslt.get("dataset_info"))
+                    kwargs["dag_run"].conf["processed_datasets"].append(uuid)
+                else:
                     if ds_rslt["creation_action"] == "Multi-Assay Split":
                         kwargs["dag_run"].conf["component_datasets"].append(uuid)
                     else:
-                        kwargs["dag_run"].conf["processed_datasets"].append(uuid)
-                else:
-                    kwargs["dag_run"].conf["primary_datasets"].append(uuid)
+                        kwargs["dag_run"].conf["primary_datasets"].append(uuid)
 
     t_build_dataset_lists = PythonOperator(
         task_id="build_dataset_lists",