[airavata] branch develop updated: Fix bug in DefaultComputeResourceSelectionPolicy

[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 340a2fb048 Fix bug in DefaultComputeResourceSelectionPolicy
     new 141602cc88 Merge pull request #352 from isururanawaka/metaschedular
340a2fb048 is described below

commit 340a2fb048f2694c92b5aa8b9204470f9d53115c
Author: Isuru Ranawaka <irjan...@gmail.com>
AuthorDate: Fri Dec 2 10:03:10 2022 -0500

    Fix bug in DefaultComputeResourceSelectionPolicy
---
 .../engine/cr/selection/DefaultComputeResourceSelectionPolicy.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/modules/airavata-metascheduler/process-scheduler/src/main/java/org/apache/airavata/metascheduler/process/scheduling/engine/cr/selection/DefaultComputeResourceSelectionPolicy.java
 
b/modules/airavata-metascheduler/process-scheduler/src/main/java/org/apache/airavata/metascheduler/process/scheduling/engine/cr/selection/DefaultComputeResourceSelectionPolicy.java
index 49b0717a15..3a452e04eb 100644
--- 
a/modules/airavata-metascheduler/process-scheduler/src/main/java/org/apache/airavata/metascheduler/process/scheduling/engine/cr/selection/DefaultComputeResourceSelectionPolicy.java
+++ 
b/modules/airavata-metascheduler/process-scheduler/src/main/java/org/apache/airavata/metascheduler/process/scheduling/engine/cr/selection/DefaultComputeResourceSelectionPolicy.java
@@ -50,7 +50,7 @@ public class DefaultComputeResourceSelectionPolicy extends 
ComputeResourceSelect
 
             QueueStatusModel queueStatusModel = 
registryClient.getQueueStatus(hostName, queueName);
             if (queueStatusModel.isQueueUp()) {
-                Optional.of(computationalResourceSchedulingModel);
+              return  Optional.of(computationalResourceSchedulingModel);
             }
         } catch (Exception exception) {
             LOGGER.error(" Exception occurred while scheduling Process with Id 
{}", processId, exception);