[airavata] branch develop updated: Read processmodel from updated model in registry

[isjarana]

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 <irjan...@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());