DPL: propagate DataProcessor metadata to DeviceSpec

...so it can be recognized by O2ControlHelpers
AliceO2Group · Jul 7, 2023 · 37a9f48 · 37a9f48
1 parent f7a6a85
commit 37a9f48
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git 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<DataProcessorLabel> labels;
+  std::vector<DataProcessorMetadata> metadata;
 };
 
 } // namespace o2::framework

diff --git 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<DeviceSpec>& 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);