Implement OGC (un)register with airflow

unity-sds · May 7, 2024 · 9395773 · 9395773
1 parent e1354d1
commit 9395773
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/app/main.py b/app/main.py
@@ -591,7 +591,7 @@ def stop_task_instances(airflow_url, dag_id, dag_run_id, auth):
         task_instance_endpoint = (
             f"{airflow_url}/dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances/{task['task_id']}"
         )
-        update_data = {"dry_run": False, "state": "new_state"}
+        update_data = {"dry_run": False, "new_state": "failed"}
         update_response = requests.patch(task_instance_endpoint, auth=auth, json=update_data)
         update_response.raise_for_status()