From e4e751bf72dc3ad5c6c3621f662b3ba1cc6fda06 Mon Sep 17 00:00:00 2001 From: Piotr Konopka Date: Mon, 20 Nov 2023 13:55:28 +0100 Subject: [PATCH] Add missing Lifetime::Sporadic to QC inputs and outputs (#2038) ...because DPL will require the Lifetime to match between inputs and outputs. --- Framework/src/InfrastructureGenerator.cxx | 2 +- Framework/test/testCheckWorkflow.cxx | 2 +- Framework/test/testWorkflow.cxx | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/Framework/src/InfrastructureGenerator.cxx b/Framework/src/InfrastructureGenerator.cxx index a9028ec22a..116be4ea70 100644 --- a/Framework/src/InfrastructureGenerator.cxx +++ b/Framework/src/InfrastructureGenerator.cxx @@ -349,7 +349,7 @@ framework::WorkflowSpec InfrastructureGenerator::generateLocalBatchInfrastructur auto taskConfig = TaskRunnerFactory::extractConfig(infrastructureSpec.common, taskSpec, 0, 1); workflow.emplace_back(TaskRunnerFactory::create(taskConfig)); - fileSinkInputs.emplace_back(taskSpec.taskName, TaskRunner::createTaskDataOrigin(taskSpec.detectorName), TaskRunner::createTaskDataDescription(taskSpec.taskName)); + fileSinkInputs.emplace_back(taskSpec.taskName, TaskRunner::createTaskDataOrigin(taskSpec.detectorName), TaskRunner::createTaskDataDescription(taskSpec.taskName), Lifetime::Sporadic); } } diff --git a/Framework/test/testCheckWorkflow.cxx b/Framework/test/testCheckWorkflow.cxx index acf23ffa68..d2a557c015 100644 --- a/Framework/test/testCheckWorkflow.cxx +++ b/Framework/test/testCheckWorkflow.cxx @@ -110,7 +110,7 @@ class Receiver : public framework::Task { Inputs inputs; for (auto& checkName : mNames) { - inputs.push_back({ checkName, "QC", Check::createCheckDataDescription(checkName) }); + inputs.push_back({ checkName, "QC", Check::createCheckDataDescription(checkName), Lifetime::Sporadic }); } return inputs; } diff --git a/Framework/test/testWorkflow.cxx b/Framework/test/testWorkflow.cxx index 4f1af055cd..e45ac65485 100644 --- a/Framework/test/testWorkflow.cxx +++ b/Framework/test/testWorkflow.cxx @@ -74,7 +74,7 @@ WorkflowSpec defineDataProcessing(ConfigContext const&) DataProcessorSpec receiver{ "receiver", Inputs{ - { "checked-mo", "QC", Check::createCheckDataDescription(getFirstCheckName(qcConfigurationSource)), 0 } }, + { "checked-mo", "QC", Check::createCheckDataDescription(getFirstCheckName(qcConfigurationSource)), 0, Lifetime::Sporadic } }, Outputs{}, AlgorithmSpec{ [](ProcessingContext& pctx) {