airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dimuthu...@apache.org
Subject [airavata] branch staging updated: Adding task level retry counts
Date Wed, 23 Jan 2019 23:49:31 GMT
This is an automated email from the ASF dual-hosted git repository.

dimuthuupe pushed a commit to branch staging
in repository https://gitbox.apache.org/repos/asf/airavata.git


The following commit(s) were added to refs/heads/staging by this push:
     new 721dae2  Adding task level retry counts
721dae2 is described below

commit 721dae23022c66233048f56b9cf0a7c1d0507793
Author: Dimuthu Wannipurage <dimuthu.upeksha2@gmail.com>
AuthorDate: Wed Jan 23 18:49:23 2019 -0500

    Adding task level retry counts
---
 .../airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java    | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/modules/orchestrator/orchestrator-core/src/main/java/org/apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java
b/modules/orchestrator/orchestrator-core/src/main/java/org/apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java
index 9908702..255c64d 100644
--- a/modules/orchestrator/orchestrator-core/src/main/java/org/apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java
+++ b/modules/orchestrator/orchestrator-core/src/main/java/org/apache/airavata/orchestrator/cpi/impl/SimpleOrchestratorImpl.java
@@ -395,6 +395,8 @@ public class SimpleOrchestratorImpl extends AbstractOrchestrator{
         envSetupSubModel.setLocation(workingDir);
         byte[] envSetupSub = ThriftUtils.serializeThriftObject(envSetupSubModel);
         envSetupTask.setSubTaskModel(envSetupSub);
+        envSetupTask.setMaxRetry(3);
+        envSetupTask.setCurrentRetry(0);
         String envSetupTaskId = (String) registryClient.addTask(envSetupTask, processModel.getProcessId());
         envSetupTask.setTaskId(envSetupTaskId);
         envTaskIds.add(envSetupTaskId);
@@ -565,6 +567,8 @@ public class SimpleOrchestratorImpl extends AbstractOrchestrator{
         submissionSubTask.setWallTime(wallTime);
         byte[] bytes = ThriftUtils.serializeThriftObject(submissionSubTask);
         taskModel.setSubTaskModel(bytes);
+        taskModel.setMaxRetry(1);
+        taskModel.setCurrentRetry(0);
         String taskId = registryClient.addTask(taskModel, processModel.getProcessId());
         taskModel.setTaskId(taskId);
         submissionTaskIds.add(taskModel.getTaskId());
@@ -635,6 +639,8 @@ public class SimpleOrchestratorImpl extends AbstractOrchestrator{
         submodel.setProcessInput(processInput);
         submodel.setDestination(destination.toString());
         taskModel.setSubTaskModel(ThriftUtils.serializeThriftObject(submodel));
+        taskModel.setMaxRetry(3);
+        taskModel.setCurrentRetry(0);
         return taskModel;
     }
 
@@ -687,6 +693,8 @@ public class SimpleOrchestratorImpl extends AbstractOrchestrator{
             // because destination is required field we set dummy destination
             submodel.setDestination("dummy://temp/file/location");
             taskModel.setSubTaskModel(ThriftUtils.serializeThriftObject(submodel));
+            taskModel.setMaxRetry(3);
+            taskModel.setCurrentRetry(0);
             return taskModel;
         } catch (OrchestratorException e) {
            throw new OrchestratorException("Error occurred while retrieving data movement
from app catalog", e);


Mime
View raw message