You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2013/03/21 20:30:24 UTC
svn commit: r1459484 -
/airavata/trunk/modules/gfac-core/src/main/java/org/apache/airavata/gfac/provider/impl/GramProvider.java
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