Fix delete url (#4282)

This commit is contained in:
Pere Miquel Brull 2022-04-20 15:30:50 +02:00 committed by GitHub
parent 61cb071ebc
commit e8e8df60b3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -110,7 +110,7 @@ public class AirflowRESTClient {
try { try {
String token = authenticate(); String token = authenticate();
String authToken = String.format(AUTH_TOKEN, token); 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); String triggerUrl = String.format(triggerEndPoint, airflowURL, pipelineName);
JSONObject requestPayload = new JSONObject(); JSONObject requestPayload = new JSONObject();
requestPayload.put("workflow_name", pipelineName); requestPayload.put("workflow_name", pipelineName);