From 4e3d11041b18fed7d547195306766797ab1d2edf Mon Sep 17 00:00:00 2001 From: jlester-msft <47044104+jlester-msft@users.noreply.github.com> Date: Tue, 12 Mar 2024 14:11:12 -0700 Subject: [PATCH 1/2] Add jobLogger subworkflow child id and root (parent is the logger tag) --- .../lifecycle/execution/SubWorkflowExecutionActor.scala | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/engine/src/main/scala/cromwell/engine/workflow/lifecycle/execution/SubWorkflowExecutionActor.scala b/engine/src/main/scala/cromwell/engine/workflow/lifecycle/execution/SubWorkflowExecutionActor.scala index 861989de5f6..ee6a03ce07c 100644 --- a/engine/src/main/scala/cromwell/engine/workflow/lifecycle/execution/SubWorkflowExecutionActor.scala +++ b/engine/src/main/scala/cromwell/engine/workflow/lifecycle/execution/SubWorkflowExecutionActor.scala @@ -65,7 +65,7 @@ class SubWorkflowExecutionActor(key: SubWorkflowKey, override def preStart(): Unit = { context.system.eventStream.publish(SubWorkflowStart(self)) - super.preStart() + super.preStart() } private var eventList: Seq[ExecutionEvent] = Seq(ExecutionEvent(stateName.toString)) @@ -312,6 +312,8 @@ class SubWorkflowExecutionActor(key: SubWorkflowKey, } } + jobLogger.info(s"Running subworkflow: ${subWorkflowDescriptor.id}, root: ${parentWorkflow.rootWorkflow.id}") + val workflowRootEvents = buildWorkflowRootMetadataEvents(subWorkflowDescriptor) serviceRegistryActor ! PutMetadataAction(events ++ inputEvents ++ workflowRootEvents) From 7a0cb3468356944a0f883955996c9f79961df67e Mon Sep 17 00:00:00 2001 From: jlester-msft <47044104+jlester-msft@users.noreply.github.com> Date: Tue, 12 Mar 2024 14:18:07 -0700 Subject: [PATCH 2/2] remove excess indent --- .../lifecycle/execution/SubWorkflowExecutionActor.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/engine/src/main/scala/cromwell/engine/workflow/lifecycle/execution/SubWorkflowExecutionActor.scala b/engine/src/main/scala/cromwell/engine/workflow/lifecycle/execution/SubWorkflowExecutionActor.scala index ee6a03ce07c..75649ebf547 100644 --- a/engine/src/main/scala/cromwell/engine/workflow/lifecycle/execution/SubWorkflowExecutionActor.scala +++ b/engine/src/main/scala/cromwell/engine/workflow/lifecycle/execution/SubWorkflowExecutionActor.scala @@ -65,7 +65,7 @@ class SubWorkflowExecutionActor(key: SubWorkflowKey, override def preStart(): Unit = { context.system.eventStream.publish(SubWorkflowStart(self)) - super.preStart() + super.preStart() } private var eventList: Seq[ExecutionEvent] = Seq(ExecutionEvent(stateName.toString))