You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2018/05/18 19:00:32 UTC
[airavata] branch staging updated: Setting user level compute
resource preferences
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 6d8082e Setting user level compute resource preferences
6d8082e is described below
commit 6d8082e3ad2991a74f657fea049fd5f982b1d8ef
Author: dimuthu <di...@gmail.com>
AuthorDate: Fri May 18 15:00:23 2018 -0400
Setting user level compute resource preferences
---
.../java/org/apache/airavata/helix/impl/task/TaskContext.java | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
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 cae8297..0bafed4 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
@@ -763,7 +763,14 @@ public class TaskContext {
ctx.setApplicationInterfaceDescription(registryClient.getApplicationInterface(processModel.getApplicationInterfaceId()));
ctx.setComputeResourceDescription(registryClient.getComputeResource(ctx.getComputeResourceId()));
ctx.setStorageResource(registryClient.getStorageResource(ctx.getStorageResourceId()));
- ctx.setUserResourceProfile(registryClient.getUserResourceProfile(processModel.getUserName(), gatewayId));
+
+ if (processModel.isUseUserCRPref()) {
+ ctx.setUserResourceProfile(registryClient.getUserResourceProfile(processModel.getUserName(), gatewayId));
+ ctx.setUserComputeResourcePreference(registryClient.getUserComputeResourcePreference(
+ processModel.getUserName(),
+ gatewayId,
+ processModel.getComputeResourceId()));
+ }
List<OutputDataObjectType> applicationOutputs = ctx.getApplicationInterfaceDescription().getApplicationOutputs();
if (applicationOutputs != null && !applicationOutputs.isEmpty()) {
--
To stop receiving notification emails like this one, please contact
dimuthuupe@apache.org.