From efe84cb78f0e72da74104dfb09d09edd9e7403b7 Mon Sep 17 00:00:00 2001 From: shahoian Date: Mon, 4 Dec 2023 15:55:59 +0100 Subject: [PATCH] Align file-push consumers inputs to Sporadic sent by the proxy --- Detectors/DCS/testWorkflow/src/dcs-config-test-workflow.cxx | 4 ++-- .../FDD/dcsmonitoring/workflow/FDDDCSConfigProcessorSpec.h | 4 ++-- .../FT0/dcsmonitoring/workflow/FT0DCSConfigProcessorSpec.h | 4 ++-- .../FV0/dcsmonitoring/workflow/FV0DCSConfigProcessorSpec.h | 4 ++-- Detectors/GRP/workflows/src/GRPLHCIFfileSpec.cxx | 4 ++-- Detectors/ITSMFT/ITS/workflow/src/DCSParserSpec.cxx | 4 ++-- .../TOF/calibration/testWorkflow/TOFDCSConfigProcessorSpec.h | 4 ++-- Detectors/TPC/dcs/src/DCSConfigSpec.cxx | 4 ++-- Detectors/ZDC/calib/testWorkflow/ZDCDCSConfigProcessorSpec.h | 4 ++-- 9 files changed, 18 insertions(+), 18 deletions(-) diff --git a/Detectors/DCS/testWorkflow/src/dcs-config-test-workflow.cxx b/Detectors/DCS/testWorkflow/src/dcs-config-test-workflow.cxx index 68a7172dddd4d..d762037445d88 100644 --- a/Detectors/DCS/testWorkflow/src/dcs-config-test-workflow.cxx +++ b/Detectors/DCS/testWorkflow/src/dcs-config-test-workflow.cxx @@ -53,8 +53,8 @@ DataProcessorSpec getDCSConsumerSpec(DetID det) procName += det.getName(); return DataProcessorSpec{ procName, - Inputs{{"confFile", ConcreteDataTypeMatcher{det.getDataOrigin(), "DCS_CONFIG_FILE"}, Lifetime::Timeframe}, - {"confFileName", ConcreteDataTypeMatcher{det.getDataOrigin(), "DCS_CONFIG_NAME"}, Lifetime::Timeframe}}, + Inputs{{"confFile", ConcreteDataTypeMatcher{det.getDataOrigin(), "DCS_CONFIG_FILE"}, Lifetime::Sporadic}, + {"confFileName", ConcreteDataTypeMatcher{det.getDataOrigin(), "DCS_CONFIG_NAME"}, Lifetime::Sporadic}}, Outputs{}, AlgorithmSpec{adaptFromTask()}, Options{}}; diff --git a/Detectors/FIT/FDD/dcsmonitoring/workflow/FDDDCSConfigProcessorSpec.h b/Detectors/FIT/FDD/dcsmonitoring/workflow/FDDDCSConfigProcessorSpec.h index 8ecbbb094cc39..b2844fc0ac95a 100644 --- a/Detectors/FIT/FDD/dcsmonitoring/workflow/FDDDCSConfigProcessorSpec.h +++ b/Detectors/FIT/FDD/dcsmonitoring/workflow/FDDDCSConfigProcessorSpec.h @@ -40,8 +40,8 @@ DataProcessorSpec getFDDDCSConfigProcessorSpec() return DataProcessorSpec{ "fdd-dcs-config-processor", - Inputs{{"inputConfig", o2::header::gDataOriginFDD, "DCS_CONFIG_FILE", Lifetime::Timeframe}, - {"inputConfigFileName", o2::header::gDataOriginFDD, "DCS_CONFIG_NAME", Lifetime::Timeframe}}, + Inputs{{"inputConfig", o2::header::gDataOriginFDD, "DCS_CONFIG_FILE", Lifetime::Sporadic}, + {"inputConfigFileName", o2::header::gDataOriginFDD, "DCS_CONFIG_NAME", Lifetime::Sporadic}}, outputs, AlgorithmSpec{adaptFromTask("FDD", ddDChM)}, Options{{"use-verbose-mode", VariantType::Bool, false, {"Use verbose mode"}}, diff --git a/Detectors/FIT/FT0/dcsmonitoring/workflow/FT0DCSConfigProcessorSpec.h b/Detectors/FIT/FT0/dcsmonitoring/workflow/FT0DCSConfigProcessorSpec.h index 62133231b8ff3..fe6701344530b 100644 --- a/Detectors/FIT/FT0/dcsmonitoring/workflow/FT0DCSConfigProcessorSpec.h +++ b/Detectors/FIT/FT0/dcsmonitoring/workflow/FT0DCSConfigProcessorSpec.h @@ -59,8 +59,8 @@ DataProcessorSpec getFT0DCSConfigProcessorSpec() return DataProcessorSpec{ "ft0-dcs-config-processor", - Inputs{{"inputConfig", o2::header::gDataOriginFT0, "DCS_CONFIG_FILE", Lifetime::Timeframe}, - {"inputConfigFileName", o2::header::gDataOriginFT0, "DCS_CONFIG_NAME", Lifetime::Timeframe}}, + Inputs{{"inputConfig", o2::header::gDataOriginFT0, "DCS_CONFIG_FILE", Lifetime::Sporadic}, + {"inputConfigFileName", o2::header::gDataOriginFT0, "DCS_CONFIG_NAME", Lifetime::Sporadic}}, outputs, AlgorithmSpec{adaptFromTask("FT0", ddDChM)}, Options{{"use-verbose-mode", VariantType::Bool, false, {"Use verbose mode"}}, diff --git a/Detectors/FIT/FV0/dcsmonitoring/workflow/FV0DCSConfigProcessorSpec.h b/Detectors/FIT/FV0/dcsmonitoring/workflow/FV0DCSConfigProcessorSpec.h index a35750cab8a1b..7c5a888312713 100644 --- a/Detectors/FIT/FV0/dcsmonitoring/workflow/FV0DCSConfigProcessorSpec.h +++ b/Detectors/FIT/FV0/dcsmonitoring/workflow/FV0DCSConfigProcessorSpec.h @@ -40,8 +40,8 @@ DataProcessorSpec getFV0DCSConfigProcessorSpec() return DataProcessorSpec{ "fv0-dcs-config-processor", - Inputs{{"inputConfig", o2::header::gDataOriginFV0, "DCS_CONFIG_FILE", Lifetime::Timeframe}, - {"inputConfigFileName", o2::header::gDataOriginFV0, "DCS_CONFIG_NAME", Lifetime::Timeframe}}, + Inputs{{"inputConfig", o2::header::gDataOriginFV0, "DCS_CONFIG_FILE", Lifetime::Sporadic}, + {"inputConfigFileName", o2::header::gDataOriginFV0, "DCS_CONFIG_NAME", Lifetime::Sporadic}}, outputs, AlgorithmSpec{adaptFromTask("FV0", ddDChM)}, Options{{"use-verbose-mode", VariantType::Bool, false, {"Use verbose mode"}}, diff --git a/Detectors/GRP/workflows/src/GRPLHCIFfileSpec.cxx b/Detectors/GRP/workflows/src/GRPLHCIFfileSpec.cxx index 37608f1bd34b1..5e5eba87dafe2 100644 --- a/Detectors/GRP/workflows/src/GRPLHCIFfileSpec.cxx +++ b/Detectors/GRP/workflows/src/GRPLHCIFfileSpec.cxx @@ -245,8 +245,8 @@ DataProcessorSpec getGRPLHCIFfileSpec() outputs.emplace_back(ConcreteDataTypeMatcher{o2::calibration::Utils::gDataOriginCDBWrapper, "GRP_LHCIFData"}, Lifetime::Sporadic); return DataProcessorSpec{ "grp-lhc-if-file-processor", - Inputs{{"inputConfig", "GRP", "DCS_CONFIG_FILE", Lifetime::Timeframe}, - {"inputConfigFileName", "GRP", "DCS_CONFIG_NAME", Lifetime::Timeframe}}, + Inputs{{"inputConfig", "GRP", "DCS_CONFIG_FILE", Lifetime::Sporadic}, + {"inputConfigFileName", "GRP", "DCS_CONFIG_NAME", Lifetime::Sporadic}}, outputs, AlgorithmSpec{adaptFromTask()}, Options{{"use-verbose-mode", VariantType::Bool, false, {"Use verbose mode"}}}}; diff --git a/Detectors/ITSMFT/ITS/workflow/src/DCSParserSpec.cxx b/Detectors/ITSMFT/ITS/workflow/src/DCSParserSpec.cxx index 8cd631d0a719d..d9fd591e1039a 100644 --- a/Detectors/ITSMFT/ITS/workflow/src/DCSParserSpec.cxx +++ b/Detectors/ITSMFT/ITS/workflow/src/DCSParserSpec.cxx @@ -650,8 +650,8 @@ DataProcessorSpec getITSDCSParserSpec() { o2::header::DataOrigin detOrig = o2::header::gDataOriginITS; std::vector inputs; - inputs.emplace_back("inString", detOrig, "DCS_CONFIG_FILE", 0, Lifetime::Timeframe); - inputs.emplace_back("nameString", detOrig, "DCS_CONFIG_NAME", 0, Lifetime::Timeframe); + inputs.emplace_back("inString", detOrig, "DCS_CONFIG_FILE", 0, Lifetime::Sporadic); + inputs.emplace_back("nameString", detOrig, "DCS_CONFIG_NAME", 0, Lifetime::Sporadic); std::vector outputs; outputs.emplace_back(ConcreteDataTypeMatcher{o2::calibration::Utils::gDataOriginCDBPayload, "DCS_CONFIG"}, Lifetime::Sporadic); diff --git a/Detectors/TOF/calibration/testWorkflow/TOFDCSConfigProcessorSpec.h b/Detectors/TOF/calibration/testWorkflow/TOFDCSConfigProcessorSpec.h index 7f95bb92b9bb3..cb5687fe7b293 100644 --- a/Detectors/TOF/calibration/testWorkflow/TOFDCSConfigProcessorSpec.h +++ b/Detectors/TOF/calibration/testWorkflow/TOFDCSConfigProcessorSpec.h @@ -144,8 +144,8 @@ DataProcessorSpec getTOFDCSConfigProcessorSpec() return DataProcessorSpec{ "tof-dcs-config-processor", - Inputs{{"inputConfig", o2::header::gDataOriginTOF, "DCS_CONFIG_FILE", Lifetime::Timeframe}, - {"inputConfigFileName", o2::header::gDataOriginTOF, "DCS_CONFIG_NAME", Lifetime::Timeframe}}, + Inputs{{"inputConfig", o2::header::gDataOriginTOF, "DCS_CONFIG_FILE", Lifetime::Sporadic}, + {"inputConfigFileName", o2::header::gDataOriginTOF, "DCS_CONFIG_NAME", Lifetime::Sporadic}}, outputs, AlgorithmSpec{adaptFromTask()}, Options{{"use-verbose-mode", VariantType::Bool, false, {"Use verbose mode"}}}}; diff --git a/Detectors/TPC/dcs/src/DCSConfigSpec.cxx b/Detectors/TPC/dcs/src/DCSConfigSpec.cxx index 34270cbca528d..7f08ee9179c77 100644 --- a/Detectors/TPC/dcs/src/DCSConfigSpec.cxx +++ b/Detectors/TPC/dcs/src/DCSConfigSpec.cxx @@ -448,8 +448,8 @@ DataProcessorSpec getDCSConfigSpec() return DataProcessorSpec{ "tpc-dcs-config", - Inputs{{"inputConfig", o2::header::gDataOriginTPC, "DCS_CONFIG_FILE", Lifetime::Timeframe}, - {"inputConfigFileName", o2::header::gDataOriginTPC, "DCS_CONFIG_NAME", Lifetime::Timeframe}}, + Inputs{{"inputConfig", o2::header::gDataOriginTPC, "DCS_CONFIG_FILE", Lifetime::Sporadic}, + {"inputConfigFileName", o2::header::gDataOriginTPC, "DCS_CONFIG_NAME", Lifetime::Sporadic}}, outputs, AlgorithmSpec{adaptFromTask()}, Options{ diff --git a/Detectors/ZDC/calib/testWorkflow/ZDCDCSConfigProcessorSpec.h b/Detectors/ZDC/calib/testWorkflow/ZDCDCSConfigProcessorSpec.h index ec6b510a894aa..7b8c8aa978ec2 100644 --- a/Detectors/ZDC/calib/testWorkflow/ZDCDCSConfigProcessorSpec.h +++ b/Detectors/ZDC/calib/testWorkflow/ZDCDCSConfigProcessorSpec.h @@ -98,8 +98,8 @@ DataProcessorSpec getZDCDCSConfigProcessorSpec() return DataProcessorSpec{ "zdc-dcs-config-processor", - Inputs{{"inputConfig", o2::header::gDataOriginZDC, "DCS_CONFIG_FILE", Lifetime::Timeframe}, - {"inputConfigFileName", o2::header::gDataOriginZDC, "DCS_CONFIG_NAME", Lifetime::Timeframe}}, + Inputs{{"inputConfig", o2::header::gDataOriginZDC, "DCS_CONFIG_FILE", Lifetime::Sporadic}, + {"inputConfigFileName", o2::header::gDataOriginZDC, "DCS_CONFIG_NAME", Lifetime::Sporadic}}, outputs, AlgorithmSpec{adaptFromTask()}, Options{{"use-verbose-mode", VariantType::Bool, false, {"Use verbose mode"}}}};