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/23 23:49:31 UTC
[airavata] branch staging updated: Adding task level retry counts
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 <di...@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);