airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dimuthu...@apache.org
Subject [airavata] branch develop updated: Prioritizing group compute resource preference to be loaded into the context
Date Mon, 24 Sep 2018 18:43:32 GMT
This is an automated email from the ASF dual-hosted git repository.

dimuthuupe 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 0a8b27b  Prioritizing group compute resource preference to be loaded into the context
0a8b27b is described below

commit 0a8b27bfe7d37420ebff2ca075401ed5049d4fba
Author: Dimuthu Wannipurage <dimuthu.wannipurage@datasprouts.com>
AuthorDate: Mon Sep 24 14:43:10 2018 -0400

    Prioritizing group compute resource preference to be loaded into the context
---
 .../java/org/apache/airavata/helix/impl/task/TaskContext.java  | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/TaskContext.java
b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/TaskContext.java
index a94e7f4..9c13db1 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/TaskContext.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/TaskContext.java
@@ -770,6 +770,11 @@ public class TaskContext {
             ctx.setGatewayId(gatewayId);
             ctx.setProcessId(processId);
 
+            ctx.setGroupComputeResourcePreference(registryClient.getGroupComputeResourcePreference(processModel.getComputeResourceId(),
+                    processModel.getGroupResourceProfileId()));
+
+            ctx.setGroupResourceProfile(registryClient.getGroupResourceProfile(processModel.getGroupResourceProfileId()));
+
             ctx.setGatewayComputeResourcePreference(
                     Optional.ofNullable(registryClient.getGatewayComputeResourcePreference(
                             gatewayId,
@@ -806,11 +811,6 @@ public class TaskContext {
                             ctx.getStorageResourceId()))
                             .orElseThrow(() -> new Exception("Invalid Storage Resource
Description")));
 
-            ctx.setGroupResourceProfile(registryClient.getGroupResourceProfile(processModel.getGroupResourceProfileId()));
-
-            ctx.setGroupComputeResourcePreference(registryClient.getGroupComputeResourcePreference(processModel.getComputeResourceId(),
-                    processModel.getGroupResourceProfileId()));
-
             if (processModel.isUseUserCRPref()) {
                 ctx.setUserResourceProfile(registryClient.getUserResourceProfile(processModel.getUserName(),
gatewayId));
                 ctx.setUserComputeResourcePreference(registryClient.getUserComputeResourcePreference(


Mime
View raw message