Skip to content

Commit

Permalink
add parent to logging pipeline, fixes apache#4690
Browse files Browse the repository at this point in the history
  • Loading branch information
hansva committed Dec 10, 2024
1 parent 18df953 commit 6c546ff
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -227,6 +227,9 @@ private synchronized void executeLoggingPipeline(
LocalPipelineEngine loggingPipeline =
new LocalPipelineEngine(loggingPipelineMeta, variables, pipeline);

// Link logged pipeline as parent
loggingPipeline.setParentPipeline(pipeline);

// Flag it as a logging pipeline so we don't log ourselves...
//
loggingPipeline.getExtensionDataMap().put(PIPELINE_LOGGING_FLAG, "Y");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -191,6 +191,9 @@ private synchronized void executeLoggingPipeline(
LocalPipelineEngine loggingPipeline =
new LocalPipelineEngine(loggingPipelineMeta, variables, workflow);

// Linked logged workflow as parent
loggingPipeline.setParentWorkflow(workflow);

// Flag it as a logging pipeline so we don't log ourselves...
//
loggingPipeline.getExtensionDataMap().put(PipelineStartLoggingXp.PIPELINE_LOGGING_FLAG, "Y");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1207,7 +1207,7 @@ public static final Map<String, Object> getStateMap(PipelineMeta pipelineMeta) {
public static final PipelineUnitTest getCurrentUnitTest(PipelineMeta pipelineMeta) {
// When rendering a pipeline on a server status page we never have a current unit test
//
if ("Server".equalsIgnoreCase(Const.getHopPlatformRuntime())) {
if (!"GUI".equalsIgnoreCase(Const.getHopPlatformRuntime())) {
return null;
}
Map<String, Object> stateMap = getStateMap(pipelineMeta);
Expand Down

0 comments on commit 6c546ff

Please sign in to comment.