airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dimuthu...@apache.org
Subject [airavata] branch develop updated: Adding parsing triggering task to post workflow
Date Mon, 07 Jan 2019 17:16:14 GMT
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 <dimuthu.upeksha2@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 {


Mime
View raw message