Author: lahiru
Date: Thu Mar 21 19:30:24 2013
New Revision: 1459484
URL: http://svn.apache.org/r1459484
Log:
adding job specific info to registry.
Modified:
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/GramProvider.java
Modified:
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/GramProvider.java
URL:
http://svn.apache.org/viewvc/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/GramProvider.java?rev=1459484&r1=1459483&r2=1459484&view=diff
==============================================================================
---
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/GramProvider.java
(original)
+++
airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/GramProvider.java
Thu Mar 21 19:30:24 2013
@@ -20,6 +20,8 @@
*/
package org.apache.airavata.gfac.provider.impl;
+import org.apache.airavata.client.api.AiravataAPIInvocationException;
+import org.apache.airavata.gfac.Constants;
import org.apache.airavata.gfac.GFacException;
import org.apache.airavata.gfac.JobSubmissionFault;
import org.apache.airavata.gfac.context.JobExecutionContext;
@@ -29,6 +31,7 @@ import org.apache.airavata.gfac.provider
import org.apache.airavata.gfac.provider.GFacProviderException;
import org.apache.airavata.gfac.utils.GramJobSubmissionListener;
import org.apache.airavata.gfac.utils.GramProviderUtils;
+import org.apache.airavata.registry.api.workflow.WorkflowNodeGramData;
import org.apache.airavata.schemas.gfac.ApplicationDeploymentDescriptionType;
import org.apache.airavata.schemas.gfac.GlobusHostType;
import org.globus.gram.GramException;
@@ -77,7 +80,15 @@ public class GramProvider implements GFa
job.request(gateKeeper, false, false);
String gramJobid = job.getIDAsString();
log.info("JobID = " + gramJobid);
-
+ String experimentID = (String)
jobExecutionContext.getProperty(Constants.PROP_TOPIC);
+ String nodeID =
(String)jobExecutionContext.getProperty(Constants.PROP_WORKFLOW_NODE_ID);
+ String hostName =
jobExecutionContext.getApplicationContext().getHostDescription().getType().getHostName();
+ WorkflowNodeGramData workflowNodeGramData = new
WorkflowNodeGramData(experimentID, nodeID, hostName, job.getRSL(),
job.getIDAsString());
+ try {
+
jobExecutionContext.getGFacConfiguration().getAiravataAPI().getProvenanceManager().updateWorkflowNodeGramData(workflowNodeGramData);
+ } catch (AiravataAPIInvocationException e) {
+ throw new GFacProviderException(e.getMessage(), e,
jobExecutionContext);
+ }
log.info(buf.toString());
/*
* Block untill job is done
