From e8e8df60b35210bf573ad60d4a6eb05d35599e92 Mon Sep 17 00:00:00 2001 From: Pere Miquel Brull Date: Wed, 20 Apr 2022 15:30:50 +0200 Subject: [PATCH] Fix delete url (#4282) --- .../org/openmetadata/catalog/airflow/AirflowRESTClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/catalog-rest-service/src/main/java/org/openmetadata/catalog/airflow/AirflowRESTClient.java b/catalog-rest-service/src/main/java/org/openmetadata/catalog/airflow/AirflowRESTClient.java index 6244e5114a2..d050a9b4527 100644 --- a/catalog-rest-service/src/main/java/org/openmetadata/catalog/airflow/AirflowRESTClient.java +++ b/catalog-rest-service/src/main/java/org/openmetadata/catalog/airflow/AirflowRESTClient.java @@ -110,7 +110,7 @@ public class AirflowRESTClient { try { String token = authenticate(); String authToken = String.format(AUTH_TOKEN, token); - String triggerEndPoint = "%s/rest_api/api?api=delete_delete&dag_id=%s"; + String triggerEndPoint = "%s/rest_api/api?api=delete_dag&dag_id=%s"; String triggerUrl = String.format(triggerEndPoint, airflowURL, pipelineName); JSONObject requestPayload = new JSONObject(); requestPayload.put("workflow_name", pipelineName);