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 2ace663  Getting the last experiment status from registry
2ace663 is described below

commit 2ace6638a6a6f5a5e846e9d1d2aa551f3c00800b
Author: Dimuthu Wannipurage <[email protected]>
AuthorDate: Sat Jul 20 01:11:57 2019 -0400

    Getting the last experiment status from registry
---
 .../org/apache/airavata/api/server/handler/AiravataServerHandler.java  | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
 
b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
index 5c322ee..ca9b95e 100644
--- 
a/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
+++ 
b/airavata-api/airavata-api-server/src/main/java/org/apache/airavata/api/server/handler/AiravataServerHandler.java
@@ -2205,11 +2205,12 @@ public class AiravataServerHandler implements 
Airavata.Iface {
         RegistryService.Client regClient = registryClientPool.getResource();
         try {
             ExperimentModel existingExperiment = 
regClient.getExperiment(airavataExperimentId);
+            ExperimentStatus experimentLastStatus = 
regClient.getExperimentStatus(airavataExperimentId);
             if (existingExperiment == null){
                 logger.error(airavataExperimentId, "Error while cancelling 
experiment {}, experiment doesn't exist.", airavataExperimentId);
                 throw new ExperimentNotFoundException("Requested experiment id 
" + airavataExperimentId + " does not exist in the system..");
             }
-            switch 
(existingExperiment.getExperimentStatus().get(0).getState()) {
+            switch (experimentLastStatus.getState()) {
                 case COMPLETED: case CANCELED: case FAILED: case CANCELING:
                     logger.warn("Can't terminate already {} experiment", 
existingExperiment.getExperimentStatus().get(0).getState().name());
                     break;

Reply via email to