You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ra...@apache.org on 2014/05/06 23:03:03 UTC
git commit: Updated to handle project changes. AIRAVATA-1182
Repository: airavata
Updated Branches:
refs/heads/master b7fea7112 -> bee2dac84
Updated to handle project changes. AIRAVATA-1182
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/bee2dac8
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/bee2dac8
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/bee2dac8
Branch: refs/heads/master
Commit: bee2dac848e921c70e2190d190c929c29a668bf8
Parents: b7fea71
Author: raminder <ra...@apache.org>
Authored: Tue May 6 17:02:23 2014 -0400
Committer: raminder <ra...@apache.org>
Committed: Tue May 6 17:02:23 2014 -0400
----------------------------------------------------------------------
.../client/samples/CreateLaunchExperiment.java | 33 +++++++++++++-------
1 file changed, 21 insertions(+), 12 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/bee2dac8/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java
----------------------------------------------------------------------
diff --git a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java
index 19d9513..4d04dc2 100644
--- a/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java
+++ b/airavata-api/airavata-client-sdks/java-client-samples/src/main/java/org/apache/airavata/client/samples/CreateLaunchExperiment.java
@@ -62,6 +62,7 @@ public class CreateLaunchExperiment {
final Airavata.Client airavata = AiravataClientFactory.createAiravataClient(THRIFT_SERVER_HOST, THRIFT_SERVER_PORT);
System.out.println("API version is " + airavata.GetAPIVersion());
// addDescriptors();
+
// final String expId = createExperimentForSSHHost(airavata);
// final String expId = createExperimentForSSHHost(airavata);
// final String expId = createExperimentForTrestles(airavata);
@@ -83,11 +84,6 @@ public class CreateLaunchExperiment {
System.out.println(" project name : " + pr.getName());
}
-// try {
-// Thread.sleep(20000);
-// } catch (InterruptedException e) {
-// e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
-// }
Thread monitor = (new Thread(){
public void run() {
Map<String, JobStatus> jobStatuses = null;
@@ -108,6 +104,7 @@ public class CreateLaunchExperiment {
}
}
}
+ System.out.println(airavata.getExperimentStatus(expId));
Thread.sleep(5000);
} catch (Exception e) {
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
@@ -115,14 +112,26 @@ public class CreateLaunchExperiment {
}
}
});
-// monitor.start();
+ monitor.start();
try {
monitor.join();
} catch (InterruptedException e) {
e.printStackTrace(); //To change body of catch statement use File | Settings | File Templates.
}
-
-// Experiment experiment = airavata.getExperiment(expId);
+ try {
+ Thread.sleep(5000);
+ } catch (InterruptedException e) {
+ e.printStackTrace(); // To change body of catch statement use
+ // File | Settings | File Templates.
+ }
+
+ System.out.println(airavata.getExperimentStatus(expId));
+ List<DataObjectType> output = airavata.getExperimentOutputs(expId);
+ for (DataObjectType dataObjectType : output) {
+ System.out.println(dataObjectType.getKey() + " : " + dataObjectType.getType() + " : " + dataObjectType.getValue());
+
+
+ }
// System.out.println("retrieved exp id : " + experiment.getExperimentID());
} catch (Exception e) {
logger.error("Error while connecting with server", e.getMessage());
@@ -181,7 +190,7 @@ public class CreateLaunchExperiment {
exOut.add(output);
Experiment simpleExperiment =
- ExperimentModelUtil.createSimpleExperiment("project1", "admin", "echoExperiment", "SimpleEcho2", "SimpleEcho2", exInputs);
+ ExperimentModelUtil.createSimpleExperiment("default", "admin", "echoExperiment", "SimpleEcho2", "SimpleEcho2", exInputs);
simpleExperiment.setExperimentOutputs(exOut);
ComputationalResourceScheduling scheduling = ExperimentModelUtil.createComputationResourceScheduling("trestles.sdsc.edu", 1, 1, 1, "normal", 0, 0, 1, "sds128");
@@ -280,7 +289,7 @@ public class CreateLaunchExperiment {
output.setValue("");
exOut.add(output);
- Project project = ProjectModelUtil.createProject("project1", "admin", "test project");
+ Project project = ProjectModelUtil.createProject("default", "admin", "test project");
String projectId = client.createProject(project, "admin");
Experiment simpleExperiment =
@@ -325,7 +334,7 @@ public class CreateLaunchExperiment {
output.setValue("");
exOut.add(output);
- Project project = ProjectModelUtil.createProject("project1", "admin", "test project");
+ Project project = ProjectModelUtil.createProject("default", "admin", "test project");
String projectId = client.createProject(project, "admin");
Experiment simpleExperiment =
@@ -371,7 +380,7 @@ public class CreateLaunchExperiment {
output.setValue("");
exOut.add(output);
- Project project = ProjectModelUtil.createProject("project1", "admin", "test project");
+ Project project = ProjectModelUtil.createProject("default", "admin", "test project");
String projectId = client.createProject(project, "admin");
Experiment simpleExperiment =