You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by bf...@apache.org on 2011/02/18 01:40:37 UTC
svn commit: r1071847 -
/oodt/branches/wengine-branch/pge/src/main/java/org/apache/oodt/cas/pge/PGETaskInstance.java
Author: bfoster
Date: Fri Feb 18 00:40:36 2011
New Revision: 1071847
URL: http://svn.apache.org/viewvc?rev=1071847&view=rev
Log:
- updates its state's message with host and exe directory
-------------------------
Modified:
oodt/branches/wengine-branch/pge/src/main/java/org/apache/oodt/cas/pge/PGETaskInstance.java
Modified: oodt/branches/wengine-branch/pge/src/main/java/org/apache/oodt/cas/pge/PGETaskInstance.java
URL: http://svn.apache.org/viewvc/oodt/branches/wengine-branch/pge/src/main/java/org/apache/oodt/cas/pge/PGETaskInstance.java?rev=1071847&r1=1071846&r2=1071847&view=diff
==============================================================================
--- oodt/branches/wengine-branch/pge/src/main/java/org/apache/oodt/cas/pge/PGETaskInstance.java (original)
+++ oodt/branches/wengine-branch/pge/src/main/java/org/apache/oodt/cas/pge/PGETaskInstance.java Fri Feb 18 00:40:36 2011
@@ -58,9 +58,11 @@ import org.apache.oodt.commons.xml.XMLUt
//JPL OODT imports
import org.apache.oodt.cas.workflow.instance.TaskInstance;
import org.apache.oodt.cas.workflow.metadata.ControlMetadata;
+import org.apache.oodt.cas.workflow.metadata.WorkflowMetKeys;
import org.apache.oodt.cas.workflow.state.results.ResultsFailureState;
import org.apache.oodt.cas.workflow.state.results.ResultsState;
import org.apache.oodt.cas.workflow.state.results.ResultsSuccessState;
+import org.apache.oodt.cas.workflow.state.running.ExecutingState;
import org.apache.oodt.cas.workflow.util.ScriptFile;
import org.apache.oodt.cas.filemgr.ingest.StdIngester;
import org.apache.oodt.cas.filemgr.system.XmlRpcFileManagerClient;
@@ -96,6 +98,14 @@ public class PGETaskInstance extends Tas
return new XmlFilePgeConfigBuilder().build(ctrlMetadata);
}
+ protected void updateStateWithExeDirectory(PgeConfig pgeConfig, ControlMetadata ctrlMetadata) {
+ try {
+ this.syncState(new ExecutingState("Starting execution on " + ctrlMetadata.getMetadata(WorkflowMetKeys.HOST) + " in directory '" + pgeConfig.getExeDir()));
+ }catch (Exception e) {
+ LOG.log(Level.SEVERE, "Failed to update state with exe directory : " + e.getMessage(), e);
+ }
+ }
+
protected void runPropertyAdders(PgeConfig pgeConfig, ControlMetadata ctrlMetadata) throws Exception {
try {
// load/run property adders
@@ -432,6 +442,7 @@ public class PGETaskInstance extends Tas
try {
//Initialization
PgeConfig pgeConfig = this.createPgeConfig(ctrlMetadata);
+ this.updateStateWithExeDirectory(pgeConfig, ctrlMetadata);
this.runPropertyAdders(pgeConfig, ctrlMetadata);
//PGE Setup