Commit 57e73306 authored by Dania Kodeih (Microsoft)'s avatar Dania Kodeih (Microsoft)
Browse files

Merge branch 'azure-impl' into 'master'

workflow-azure integration issue fix.

See merge request !6
parents 7e99c9b9 7c20e838
Pipeline #4860 passed with stages
in 17 minutes and 28 seconds
......@@ -40,6 +40,7 @@ public class SubmitIngestServiceImpl implements ISubmitIngestService {
private static Logger logger = Logger.getLogger(SubmitIngestServiceImpl.class.getName());
private final static String AIRFLOW_PAYLOAD_PARAMETER_NAME = "conf";
private final static String RUN_ID_PARAMETER_NAME = "run_id";
@Autowired
@Named("AIRFLOW_URL")
......@@ -55,7 +56,13 @@ public class SubmitIngestServiceImpl implements ISubmitIngestService {
dagName));
String airflowApiUrl = String.format("%s/api/experimental/dags/%s/dag_runs", airflowURL, dagName);
JSONObject requestBody = new JSONObject(data);
String workflowId = data.get(RUN_ID_PARAMETER_NAME).toString();
data.remove(RUN_ID_PARAMETER_NAME);
JSONObject requestBody = new JSONObject();
requestBody.put(RUN_ID_PARAMETER_NAME, workflowId);
requestBody.put(AIRFLOW_PAYLOAD_PARAMETER_NAME, data);
logger.log(Level.INFO, String.format("Airflow endpoint: {%s}", airflowApiUrl));
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment