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/03/24 16:22:23 UTC
svn commit: r1084997 -
/oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java
Author: bfoster
Date: Thu Mar 24 15:22:23 2011
New Revision: 1084997
URL: http://svn.apache.org/viewvc?rev=1084997&view=rev
Log:
- updated to handle case of 0 spawns
---------------------
Modified:
oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java
Modified: oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java
URL: http://svn.apache.org/viewvc/oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java?rev=1084997&r1=1084996&r2=1084997&view=diff
==============================================================================
--- oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java (original)
+++ oodt/branches/wengine-branch/wengine/src/main/java/org/apache/oodt/cas/workflow/instance/WorkflowConnectTaskInstance.java Thu Mar 24 15:22:23 2011
@@ -55,6 +55,7 @@ public class WorkflowConnectTaskInstance
public static final String N_MET_MOD_CLASS = "WorkflowConnect/NMetadataModifier/Class";
public static final String SPAWN_MODEL_ID = "WorkflowConnect/ModelId";
+ public static final String PERFORMED_SPAWNING = "WorkflowConnect/PerformedSpawning";
public static final String SPAWNED_WORKFLOWS = "WorkflowConnect/SpawnedWorkflows/InstanceIds";
public static final String SPAWNED_BY_WORKFLOW = "WorkflowConnect/SpawnedByWorkflow/InstanceId";
@@ -71,7 +72,7 @@ public class WorkflowConnectTaskInstance
@Override
protected ResultsState performExecution(ControlMetadata ctrlMetadata) {
- if (ctrlMetadata.getMetadata(SPAWNED_WORKFLOWS) == null) {
+ if (ctrlMetadata.getMetadata(PERFORMED_SPAWNING) == null) {
//Get Spawn ModelId
String spawnModelId = ctrlMetadata.getMetadata(SPAWN_MODEL_ID);
@@ -134,8 +135,9 @@ public class WorkflowConnectTaskInstance
return new ResultsFailureState("Failed to start workflow ModelId '" + spawnModelId + "' [i = '" + i + "'] : " + e.getMessage());
}
}
+ ctrlMetadata.replaceLocalMetadata(PERFORMED_SPAWNING, "true");
ctrlMetadata.replaceLocalMetadata(SPAWNED_WORKFLOWS, spawnedInstanceIds);
- ctrlMetadata.setAsWorkflowMetadataKey(SPAWNED_WORKFLOWS);
+ ctrlMetadata.setAsWorkflowMetadataKey(PERFORMED_SPAWNING, SPAWNED_WORKFLOWS);
//Add spawning keys to localized workflow metadata keys
Vector<String> localKeys = new Vector<String>();