You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2019/01/07 17:16:14 UTC
[airavata] branch develop updated: Adding parsing triggering task
to post workflow
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/develop by this push:
new f3abbdc Adding parsing triggering task to post workflow
f3abbdc is described below
commit f3abbdc9698e9c001f2b8411e202e0d4fda97f50
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Mon Jan 7 12:15:59 2019 -0500
Adding parsing triggering task to post workflow
---
.../airavata/helix/impl/workflow/PostWorkflowManager.java | 11 +++++++++++
1 file changed, 11 insertions(+)
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
index 5e9fdf2..6aebdd2 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
@@ -242,6 +242,17 @@ public class PostWorkflowManager extends WorkflowManager {
}
allTasks.add(completingTask);
+ ParsingTriggeringTask parsingTriggeringTask = new ParsingTriggeringTask();
+ parsingTriggeringTask.setGatewayId(experimentModel.getGatewayId());
+ parsingTriggeringTask.setExperimentId(experimentModel.getExperimentId());
+ parsingTriggeringTask.setProcessId(processModel.getProcessId());
+ parsingTriggeringTask.setTaskId("Parsing-Triggering-Task");
+ parsingTriggeringTask.setSkipTaskStatusPublish(true);
+ if (allTasks.size() > 0) {
+ allTasks.get(allTasks.size() - 1).setNextTask(new OutPort(parsingTriggeringTask.getTaskId(), parsingTriggeringTask));
+ }
+ allTasks.add(parsingTriggeringTask);
+
String workflowName = getWorkflowOperator().launchWorkflow(processId + "-POST-" + UUID.randomUUID().toString(),
new ArrayList<>(allTasks), true, false);
try {