You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2016/11/01 21:54:52 UTC
airavata git commit: Added create Cloud job submission method to
AppCatalogJPAUtils
Repository: airavata
Updated Branches:
refs/heads/develop e3da09144 -> 9d2497c3a
Added create Cloud job submission method to AppCatalogJPAUtils
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/9d2497c3
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/9d2497c3
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/9d2497c3
Branch: refs/heads/develop
Commit: 9d2497c3a46c14d998acd4e28bb273b1f29c2338
Parents: e3da091
Author: Shameera Rathnayaka <sh...@gmail.com>
Authored: Tue Nov 1 17:54:46 2016 -0400
Committer: Shameera Rathnayaka <sh...@gmail.com>
Committed: Tue Nov 1 17:54:46 2016 -0400
----------------------------------------------------------------------
.../app/catalog/util/AppCatalogJPAUtils.java | 19 +++++++++++++++++++
1 file changed, 19 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/9d2497c3/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/app/catalog/util/AppCatalogJPAUtils.java
----------------------------------------------------------------------
diff --git a/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/app/catalog/util/AppCatalogJPAUtils.java b/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/app/catalog/util/AppCatalogJPAUtils.java
index 0c3918d..bd7b442 100644
--- a/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/app/catalog/util/AppCatalogJPAUtils.java
+++ b/modules/registry/registry-core/src/main/java/org/apache/airavata/registry/core/app/catalog/util/AppCatalogJPAUtils.java
@@ -174,6 +174,13 @@ public class AppCatalogJPAUtils {
logger.error("Object should be a Ssh Job Submission.", new IllegalArgumentException());
throw new IllegalArgumentException("Object should be a Ssh Job Submission.");
}
+ case ClOUD_SUBMISSION:
+ if (o instanceof CloudJobSubmission) {
+ return createCloudJobSubmission(((CloudJobSubmission) o));
+ }else {
+ logger.error("Object should be a Cloud Job Submission.", new IllegalArgumentException());
+ throw new IllegalArgumentException("Object should be a Cloud Job Submission.");
+ }
case SCP_DATA_MOVEMENT:
if (o instanceof ScpDataMovement) {
return createScpDataMovement((ScpDataMovement) o);
@@ -668,6 +675,18 @@ public class AppCatalogJPAUtils {
return sshJobSubmissionResource;
}
+ private static AppCatalogResource createCloudJobSubmission(CloudJobSubmission o) {
+ CloudSubmissionResource cloudSubmissionResource = new CloudSubmissionResource();
+ if (o != null) {
+ cloudSubmissionResource.setJobSubmissionInterfaceId(o.getJobSubmissionInterfaceId());
+ cloudSubmissionResource.setSecurityProtocol(o.getSecurityProtocol());
+ cloudSubmissionResource.setExecutableType(o.getExecutableType());
+ cloudSubmissionResource.setUserAccountName(o.getUserAccountName());
+ cloudSubmissionResource.setNodeId(o.getNodeId());
+ }
+ return cloudSubmissionResource;
+ }
+
private static AppCatalogResource createScpDataMovement(ScpDataMovement o) {
ScpDataMovementResource scpDataMovementResource = new ScpDataMovementResource();
if (o != null) {