Skip to content

Commit 3b3a626

Browse files
authored
[OMON-491] Data Sampling: add Data Sampling tag to Monitoring metrics (#7264)
1 parent 53fb74d commit 3b3a626

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

Utilities/DataSampling/src/Dispatcher.cxx

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121
#include "Framework/DataSpecUtils.h"
2222
#include "Framework/Logger.h"
2323
#include "Framework/ConfigParamRegistry.h"
24-
#include "Framework/InputRecordWalker.h"
2524
#include "Framework/Monitoring.h"
2625
#include "Framework/DataRefUtils.h"
2726

@@ -45,7 +44,6 @@ Dispatcher::~Dispatcher() = default;
4544
void Dispatcher::init(InitContext& ctx)
4645
{
4746
LOG(DEBUG) << "Reading Data Sampling Policies...";
48-
4947
boost::property_tree::ptree policiesTree;
5048

5149
if (mReconfigurationSource.empty() == false) {
@@ -137,8 +135,8 @@ void Dispatcher::reportStats(Monitoring& monitoring) const
137135
dispatcherTotalAcceptedMessages += policy->getTotalAcceptedMessages();
138136
}
139137

140-
monitoring.send({dispatcherTotalEvaluatedMessages, "Dispatcher_messages_evaluated"});
141-
monitoring.send({dispatcherTotalAcceptedMessages, "Dispatcher_messages_passed"});
138+
monitoring.send(Metric{dispatcherTotalEvaluatedMessages, "Dispatcher_messages_evaluated"}.addTag(tags::Key::Subsystem, tags::Value::DataSampling));
139+
monitoring.send(Metric{dispatcherTotalAcceptedMessages, "Dispatcher_messages_passed"}.addTag(tags::Key::Subsystem, tags::Value::DataSampling));
142140
}
143141

144142
DataSamplingHeader Dispatcher::prepareDataSamplingHeader(const DataSamplingPolicy& policy)

0 commit comments

Comments
 (0)