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/auroraMesosIntegration Commit: 9d2497c3a46c14d998acd4e28bb273b1f29c2338 Parents: e3da091 Author: Shameera Rathnayaka <[email protected]> Authored: Tue Nov 1 17:54:46 2016 -0400 Committer: Shameera Rathnayaka <[email protected]> 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) {
