2022-06-07 23:52:16,577|||||KafkaConsumer-request-receiver-client-id|||o.o.c.c.b.m.service.KafkaMessageConsumerService|Channel sent Consumer Record : topic(cds.blueprint-processor.self-service-api.request.regression-debug) partition(0) leaderEpoch(0) offset(2) key(null) 2022-06-07 23:52:16,600|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.api.BluePrintProcessingKafkaConsumer|Consumed Message : topic(cds.blueprint-processor.self-service-api.request.regression-debug) partition(0) leaderEpoch(0) offset(2) key(null) requestID(1234), subrequestID(1234-12234) CBA(uat-imperative-workflow/1.0.0/uat-wf-parallel) 2022-06-07 23:52:16,601|||||DefaultDispatcher-worker-4|||c.o.c.c.b.selfservice.api.ExecutionServiceHandler|processing request id 1234 2022-06-07 23:52:16,609|||||DefaultDispatcher-worker-4|||c.o.c.c.b.f.workflow.audit.NoStoreAuditService|storeExecutionInput called not to store the Workflow action input details 2022-06-07 23:52:16,609|||||DefaultDispatcher-worker-4|||c.o.c.c.b.selfservice.api.ExecutionServiceHandler|StoreAuditService ID -1 2022-06-07 23:52:16,610|||||DefaultDispatcher-worker-4|||c.o.c.c.b.d.p.s.BlueprintProcessorCatalogServiceImpl|cba file name(uat-imperative-workflow), version(1.0.0) already present(/Users/jc/code/java/cds-downstream/ms/blueprintsprocessor/application/blueprints/deploy/uat-imperative-workflow/1.0.0) 2022-06-07 23:52:16,610|||||DefaultDispatcher-worker-4|||c.o.c.c.b.selfservice.api.ExecutionServiceHandler|blueprint base path blueprints/deploy/uat-imperative-workflow/1.0.0 2022-06-07 23:52:16,611|||||DefaultDispatcher-worker-4|||c.o.c.c.c.c.utils.BluePrintMetadataUtils$Companion|Reading blueprint type(DEFAULT) path(blueprints/deploy/uat-imperative-workflow/1.0.0) and entry definition file (Definitions/uat-imperative-workflow.json) 2022-06-07 23:52:16,623|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|Deriving input data for workflow: (uat-wf-parallel) 2022-06-07 23:52:16,624|||||DefaultDispatcher-worker-2|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|Execute node(START) -> executed state(SUCCESS) 2022-06-07 23:52:16,625|||||DefaultDispatcher-worker-2|||o.o.c.c.b.s.w.ImperativeBluePrintWorkflowService|Executing workflow(uat-wf-parallel[1234])'s step(execute-B) 2022-06-07 23:52:16,625|||||DefaultDispatcher-worker-3|||o.o.c.c.b.s.w.ImperativeBluePrintWorkflowService|Executing workflow(uat-wf-parallel[1234])'s step(execute-A) 2022-06-07 23:52:16,625|||||DefaultDispatcher-worker-2|||o.o.c.c.b.s.workflow.NodeTemplateExecutionService|executing node template(execute-script-2) component(component-script-executor) interface(ComponentScriptExecutor) operation(process) on host (SELF) with timeout(180) sec. 2022-06-07 23:52:16,625|||||DefaultDispatcher-worker-3|||o.o.c.c.b.s.workflow.NodeTemplateExecutionService|executing node template(execute-script-1) component(component-script-executor) interface(ComponentScriptExecutor) operation(process) on host (SELF) with timeout(180) sec. 2022-06-07 23:52:16,626|||||DefaultDispatcher-worker-2|||o.o.c.c.b.s.execution.AbstractComponentFunction|preparing request id(1234) for workflow(uat-wf-parallel) step(execute-B) 2022-06-07 23:52:16,626|||||DefaultDispatcher-worker-3|||o.o.c.c.b.s.execution.AbstractComponentFunction|preparing request id(1234) for workflow(uat-wf-parallel) step(execute-A) 2022-06-07 23:52:16,626|||||DefaultDispatcher-worker-2|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationInputs for node template (execute-script-2), interface name(ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,626|||||DefaultDispatcher-worker-3|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationInputs for node template (execute-script-1), interface name(ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,627|||||DefaultDispatcher-worker-2|||c.o.c.c.c.core.service.BluePrintRuntimeService|input definition for node template (execute-script-2), values ({script-type="kotlin", script-class-reference="cba.cds.uat.TestScript"}) 2022-06-07 23:52:16,627|||||DefaultDispatcher-worker-3|||c.o.c.c.c.core.service.BluePrintRuntimeService|input definition for node template (execute-script-1), values ({script-type="kotlin", script-class-reference="cba.cds.uat.TestScript"}) 2022-06-07 23:52:16,627|||||DefaultDispatcher-worker-3|||o.o.c.c.b.s.e.ComponentFunctionScriptingService|creating component function of script type(kotlin), reference name(cba.cds.uat.TestScript) and instanceDependencies([]) 2022-06-07 23:52:16,627|||||DefaultDispatcher-worker-2|||o.o.c.c.b.s.e.ComponentFunctionScriptingService|creating component function of script type(kotlin), reference name(cba.cds.uat.TestScript) and instanceDependencies([]) 2022-06-07 23:52:16,627|||||DefaultDispatcher-worker-3|||cba.cds.uat.TestScript|running step execute-A, should fail: false 2022-06-07 23:52:16,627|||||DefaultDispatcher-worker-2|||cba.cds.uat.TestScript|running step execute-B, should fail: false 2022-06-07 23:52:16,627|||||DefaultDispatcher-worker-3|||o.o.c.c.b.s.execution.AbstractComponentFunction|Preparing Response... 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-2|||o.o.c.c.b.s.execution.AbstractComponentFunction|Preparing Response... 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-3|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationOutputs for node template (execute-script-1),interface name (ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-2|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationOutputs for node template (execute-script-2),interface name (ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-3|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|Execute node(execute-A) -> executed state(SUCCESS) 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-2|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|Execute node(execute-B) -> executed state(SUCCESS) 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|node(clean-up) is waiting for incoming edges([execute-B>clean-up/FAILURE(NOT_STARTED), finalize>clean-up/SUCCESS(NOT_STARTED), finalize>clean-up/FAILURE(NOT_STARTED)]) 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|node(finalize) is waiting for incoming edges([execute-B>finalize/SUCCESS(NOT_STARTED)]) 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|node(clean-up) is waiting for incoming edges([finalize>clean-up/SUCCESS(NOT_STARTED), finalize>clean-up/FAILURE(NOT_STARTED)]) 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.w.ImperativeBluePrintWorkflowService|Executing workflow(uat-wf-parallel[1234])'s step(finalize) 2022-06-07 23:52:16,628|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.workflow.NodeTemplateExecutionService|executing node template(execute-script-3) component(component-script-executor) interface(ComponentScriptExecutor) operation(process) on host (SELF) with timeout(180) sec. 2022-06-07 23:52:16,629|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.execution.AbstractComponentFunction|preparing request id(1234) for workflow(uat-wf-parallel) step(finalize) 2022-06-07 23:52:16,629|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationInputs for node template (execute-script-3), interface name(ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,630|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|input definition for node template (execute-script-3), values ({script-type="kotlin", script-class-reference="cba.cds.uat.TestScript"}) 2022-06-07 23:52:16,630|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.e.ComponentFunctionScriptingService|creating component function of script type(kotlin), reference name(cba.cds.uat.TestScript) and instanceDependencies([]) 2022-06-07 23:52:16,630|||||DefaultDispatcher-worker-4|||cba.cds.uat.TestScript|running step finalize, should fail: false 2022-06-07 23:52:16,630|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.execution.AbstractComponentFunction|Preparing Response... 2022-06-07 23:52:16,630|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationOutputs for node template (execute-script-3),interface name (ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,630|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|Execute node(finalize) -> executed state(SUCCESS) 2022-06-07 23:52:16,631|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|node(clean-up) is waiting for incoming edges([finalize>clean-up/FAILURE(NOT_STARTED)]) 2022-06-07 23:52:16,631|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.w.ImperativeBluePrintWorkflowService|Executing workflow(uat-wf-parallel[1234])'s step(clean-up) 2022-06-07 23:52:16,631|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.workflow.NodeTemplateExecutionService|executing node template(execute-script-4) component(component-script-executor) interface(ComponentScriptExecutor) operation(process) on host (SELF) with timeout(180) sec. 2022-06-07 23:52:16,632|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.execution.AbstractComponentFunction|preparing request id(1234) for workflow(uat-wf-parallel) step(clean-up) 2022-06-07 23:52:16,632|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationInputs for node template (execute-script-4), interface name(ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,632|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|input definition for node template (execute-script-4), values ({script-type="kotlin", script-class-reference="cba.cds.uat.TestScript"}) 2022-06-07 23:52:16,632|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.e.ComponentFunctionScriptingService|creating component function of script type(kotlin), reference name(cba.cds.uat.TestScript) and instanceDependencies([]) 2022-06-07 23:52:16,637|||||DefaultDispatcher-worker-4|||cba.cds.uat.TestScript|running step clean-up, should fail: false 2022-06-07 23:52:16,637|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.execution.AbstractComponentFunction|Preparing Response... 2022-06-07 23:52:16,637|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationOutputs for node template (execute-script-4),interface name (ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,637|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|Execute node(clean-up) -> executed state(SUCCESS) 2022-06-07 23:52:16,637|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|node(collect) is waiting for incoming edges([clean-up>collect/FAILURE(NOT_STARTED)]) 2022-06-07 23:52:16,638|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.w.ImperativeBluePrintWorkflowService|Executing workflow(uat-wf-parallel[1234])'s step(collect) 2022-06-07 23:52:16,638|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.workflow.NodeTemplateExecutionService|executing node template(collect-results) component(component-script-executor) interface(ComponentScriptExecutor) operation(process) on host (SELF) with timeout(180) sec. 2022-06-07 23:52:16,638|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.execution.AbstractComponentFunction|preparing request id(1234) for workflow(uat-wf-parallel) step(collect) 2022-06-07 23:52:16,638|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationInputs for node template (collect-results), interface name(ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,638|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|input definition for node template (collect-results), values ({script-type="kotlin", script-class-reference="cba.cds.uat.CollectorScript"}) 2022-06-07 23:52:16,639|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.e.ComponentFunctionScriptingService|creating component function of script type(kotlin), reference name(cba.cds.uat.CollectorScript) and instanceDependencies([]) 2022-06-07 23:52:16,639|||||kafka-producer-network-thread | audit-request-producer-client-id-7f122|||o.o.c.c.b.m.service.KafkaMessageProducerService|ExecutionServiceInput published : topic(cds.blueprint-processor.self-service-api.audit.request.regression-debug) partition(0) offset(5) requestID(1234), subrequestID(1234-12234) CBA(uat-imperative-workflow/1.0.0/uat-wf-parallel). 2022-06-07 23:52:16,640|||||DefaultDispatcher-worker-4|||cba.cds.uat.CollectorScript|Collected results: {"execute-script-1":"SUCCEEDED","execute-script-2":"SUCCEEDED","execute-script-3":"SUCCEEDED","execute-script-4":"SUCCEEDED"} 2022-06-07 23:52:16,640|||||DefaultDispatcher-worker-4|||o.o.c.c.b.s.execution.AbstractComponentFunction|Preparing Response... 2022-06-07 23:52:16,640|||||DefaultDispatcher-worker-4|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveNodeTemplateInterfaceOperationOutputs for node template (collect-results),interface name (ComponentScriptExecutor), operationName(process) 2022-06-07 23:52:16,640|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|Execute node(collect) -> executed state(SUCCESS) 2022-06-07 23:52:16,641|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|Execute node(END) -> executed state(SUCCESS) 2022-06-07 23:52:16,641|||||DefaultDispatcher-worker-4|||o.o.c.c.c.c.s.AbstractBluePrintWorkFlowService|workflow(1234) nodes completed with (0)exceptions 2022-06-07 23:52:16,641|||||DefaultDispatcher-worker-3|||c.o.c.c.c.core.service.BluePrintRuntimeService|resolveWorkflowOutputs for workflow(uat-wf-parallel) 2022-06-07 23:52:16,647|||||DefaultDispatcher-worker-3|||c.o.c.c.b.f.workflow.audit.NoStoreAuditService|storeExecutionOutput called not to store the Workflow action output details correlationUUID 17f9087c-9ad5-44cd-9c69-ca650eb565ac auditStoreId -1 2022-06-07 23:52:16,657|||||DefaultDispatcher-worker-3|||org.apache.kafka.common.utils.AppInfoParser|Kafka version: 2.5.1 2022-06-07 23:52:16,658|||||DefaultDispatcher-worker-3|||org.apache.kafka.common.utils.AppInfoParser|Kafka commitId: 0efa8fb0f4c73d92 2022-06-07 23:52:16,658|||||DefaultDispatcher-worker-3|||org.apache.kafka.common.utils.AppInfoParser|Kafka startTimeMs: 1654645936657 2022-06-07 23:52:16,675|||||kafka-producer-network-thread | audit-response-producer-client-id-86061|||o.o.c.c.b.m.service.KafkaMessageProducerService|ExecutionServiceOutput published : topic(cds.blueprint-processor.self-service-api.audit.response.regression-debug) partition(0) offset(5) requestID(1234), subrequestID(1234-12234) CBA(uat-imperative-workflow/1.0.0/uat-wf-parallel). 2022-06-07 23:52:16,735|||||kafka-producer-network-thread | request-producer-client-id-45725|||org.apache.kafka.clients.Metadata|[Producer clientId=request-producer-client-id-45725] Cluster ID: BeEtLfKiSCe_z-dMlcxJJQ 2022-06-07 23:52:16,809|||||kafka-producer-network-thread | request-producer-client-id-45725|||o.o.c.c.b.m.service.KafkaMessageProducerService|ExecutionServiceOutput published : topic(cds.blueprint-processor.self-service-api.response.regression-debug) partition(0) offset(2) requestID(1234), subrequestID(1234-12234) CBA(uat-imperative-workflow/1.0.0/uat-wf-parallel).