You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by is...@apache.org on 2023/03/10 16:20:16 UTC
[airavata] branch develop updated: Read processmodel from updated model in registry
This is an automated email from the ASF dual-hosted git repository.
isjarana 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 e69ed0a66d Read processmodel from updated model in registry
new c97ac4890c Merge pull request #404 from isururanawaka/metaschedular
e69ed0a66d is described below
commit e69ed0a66d4d7808fb200092763cf082cd10d15b
Author: Isuru Ranawaka <ir...@gmail.com>
AuthorDate: Fri Mar 10 11:19:20 2023 -0500
Read processmodel from updated model in registry
---
.../apache/airavata/orchestrator/server/OrchestratorServerHandler.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java b/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java
index 9e3955871a..dd9015e45b 100644
--- a/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java
+++ b/modules/orchestrator/orchestrator-service/src/main/java/org/apache/airavata/orchestrator/server/OrchestratorServerHandler.java
@@ -254,7 +254,8 @@ public class OrchestratorServerHandler implements OrchestratorService.Iface {
ProcessScheduler scheduler = new ProcessSchedulerImpl();
if (!experiment.getUserConfigurationData().isAiravataAutoSchedule() || scheduler.canLaunch(experimentId)) {
if (experiment.getUserConfigurationData().isAiravataAutoSchedule()){
- for (ProcessModel processModel : processes) {
+ List<ProcessModel> processModels = registryClient.getProcessList(experimentId);
+ for (ProcessModel processModel : processModels) {
String taskDag = orchestrator.createAndSaveTasks(gatewayId, processModel);
processModel.setTaskDag(taskDag);
registryClient.updateProcess(processModel, processModel.getProcessId());