From 37a9f48e4970ff2fd971af27b124df0813100aec Mon Sep 17 00:00:00 2001 From: Piotr Konopka Date: Wed, 28 Jun 2023 15:10:17 +0200 Subject: [PATCH] DPL: propagate DataProcessor metadata to DeviceSpec ...so it can be recognized by O2ControlHelpers --- Framework/Core/include/Framework/DeviceSpec.h | 1 + Framework/Core/src/DeviceSpecHelpers.cxx | 6 ++++-- 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/Framework/Core/include/Framework/DeviceSpec.h b/Framework/Core/include/Framework/DeviceSpec.h index 87e6f067b5dcc..6a11146283190 100644 --- a/Framework/Core/include/Framework/DeviceSpec.h +++ b/Framework/Core/include/Framework/DeviceSpec.h @@ -81,6 +81,7 @@ struct DeviceSpec { ComputingResource resource; unsigned short resourceMonitoringInterval; std::vector labels; + std::vector metadata; }; } // namespace o2::framework diff --git a/Framework/Core/src/DeviceSpecHelpers.cxx b/Framework/Core/src/DeviceSpecHelpers.cxx index d152b4658d00c..2041dc5a38a09 100644 --- a/Framework/Core/src/DeviceSpecHelpers.cxx +++ b/Framework/Core/src/DeviceSpecHelpers.cxx @@ -542,7 +542,8 @@ void DeviceSpecHelpers::processOutEdgeActions(ConfigContext const& configContext .inputTimesliceId = edge.producerTimeIndex, .maxInputTimeslices = processor.maxInputTimeslices, .resource = {acceptedOffer}, - .labels = processor.labels}); + .labels = processor.labels, + .metadata = processor.metadata}); /// If any of the inputs or outputs are "Lifetime::OutOfBand" /// create the associated channels. // @@ -828,7 +829,8 @@ void DeviceSpecHelpers::processInEdgeActions(std::vector& devices, .inputTimesliceId = edge.timeIndex, .maxInputTimeslices = processor.maxInputTimeslices, .resource = {acceptedOffer}, - .labels = processor.labels}; + .labels = processor.labels, + .metadata = processor.metadata}; if (processor.maxInputTimeslices != 1) { device.id += "_t" + std::to_string(edge.timeIndex);