[airavata] branch develop updated: Process synchornization after input change

[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 7925f86801 Process synchornization after input change
     new ab68e54c68 Merge pull request #405 from isururanawaka/metaschedular
7925f86801 is described below

commit 7925f86801cb8e7f80c0b6d72d2cbaa8bfe3bd59
Author: Isuru Ranawaka <irjan...@gmail.com>
AuthorDate: Fri Mar 10 13:12:43 2023 -0500

    Process synchornization after input change
---
 .../airavata/orchestrator/server/OrchestratorServerHandler.java      | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 dd9015e45b..8a64de7757 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
@@ -240,11 +240,12 @@ public class OrchestratorServerHandler implements 
OrchestratorService.Iface {
 
 
 
+
                     if 
(!experiment.getUserConfigurationData().isAiravataAutoSchedule()) {
                         String taskDag = 
orchestrator.createAndSaveTasks(gatewayId, processModel);
                         processModel.setTaskDag(taskDag);
-                        registryClient.updateProcess(processModel, 
processModel.getProcessId());
                     }
+                    registryClient.updateProcess(processModel, 
processModel.getProcessId());
                 }
 
                 if 
(!experiment.getUserConfigurationData().isAiravataAutoSchedule() && 
!validateProcess(experimentId, processes)) {
@@ -260,7 +261,7 @@ public class OrchestratorServerHandler implements 
OrchestratorService.Iface {
                             processModel.setTaskDag(taskDag);
                             registryClient.updateProcess(processModel, 
processModel.getProcessId());
                         }
-                        if (!validateProcess(experimentId, processes)) {
+                        if (!validateProcess(experimentId, processModels)) {
                             throw new Exception("Validating process fails for 
given experiment Id : " + experimentId);
                         }
                     }