Repository: oodt Updated Branches: refs/heads/master 96842a429 -> 2235bd953
ODT-862: Include the Workflow ID as part of the standard metadata Project: http://git-wip-us.apache.org/repos/asf/oodt/repo Commit: http://git-wip-us.apache.org/repos/asf/oodt/commit/2235bd95 Tree: http://git-wip-us.apache.org/repos/asf/oodt/tree/2235bd95 Diff: http://git-wip-us.apache.org/repos/asf/oodt/diff/2235bd95 Branch: refs/heads/master Commit: 2235bd953abff5b50f5ad148556e678efaec74e6 Parents: 96842a4 Author: Luca Cinquini <[email protected]> Authored: Mon Oct 26 09:34:40 2015 -0600 Committer: Luca Cinquini <[email protected]> Committed: Mon Oct 26 09:34:40 2015 -0600 ---------------------------------------------------------------------- .../cas/workflow/engine/IterativeWorkflowProcessorThread.java | 5 +++++ .../java/org/apache/oodt/cas/workflow/metadata/CoreMetKeys.java | 4 ++++ 2 files changed, 9 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/oodt/blob/2235bd95/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/IterativeWorkflowProcessorThread.java ---------------------------------------------------------------------- diff --git a/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/IterativeWorkflowProcessorThread.java b/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/IterativeWorkflowProcessorThread.java index 2a8020f..a9d7424 100644 --- a/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/IterativeWorkflowProcessorThread.java +++ b/workflow/src/main/java/org/apache/oodt/cas/workflow/engine/IterativeWorkflowProcessorThread.java @@ -231,6 +231,11 @@ public class IterativeWorkflowProcessorThread implements WorkflowStatus, getHostname()); workflowInst.getSharedContext().replaceMetadata(WORKFLOW_MANAGER_URL, this.wmgrParentUrl.toString()); + workflowInst.getSharedContext().replaceMetadata(WORKFLOW_ID, + workflowInst.getParentChildWorkflow().getId()); + workflowInst.getSharedContext().replaceMetadata(WORKFLOW_NAME, + workflowInst.getParentChildWorkflow().getName()); + if (rClient != null) { // build up the Job http://git-wip-us.apache.org/repos/asf/oodt/blob/2235bd95/workflow/src/main/java/org/apache/oodt/cas/workflow/metadata/CoreMetKeys.java ---------------------------------------------------------------------- diff --git a/workflow/src/main/java/org/apache/oodt/cas/workflow/metadata/CoreMetKeys.java b/workflow/src/main/java/org/apache/oodt/cas/workflow/metadata/CoreMetKeys.java index 5951094..0c96b6d 100644 --- a/workflow/src/main/java/org/apache/oodt/cas/workflow/metadata/CoreMetKeys.java +++ b/workflow/src/main/java/org/apache/oodt/cas/workflow/metadata/CoreMetKeys.java @@ -31,6 +31,10 @@ public interface CoreMetKeys { String TASK_ID = "TaskId"; String WORKFLOW_INST_ID = "WorkflowInstId"; + + String WORKFLOW_ID = "WorkflowId"; + + String WORKFLOW_NAME = "WorkflowName"; String JOB_ID = "JobId";
