Skip to content

Commit e5b4dac

Browse files
committed
DPL Analysis: add version to the table size
1 parent 4db6e33 commit e5b4dac

File tree

1 file changed

+5
-3
lines changed

1 file changed

+5
-3
lines changed

Framework/Core/src/DataProcessor.cxx

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -107,12 +107,14 @@ void DataProcessor::doSend(DataSender& sender, ArrowContext& context, ServiceReg
107107

108108
auto origin = std::regex_replace(dh->dataOrigin.as<std::string>(), invalid_metric, "_");
109109
auto description = std::regex_replace(dh->dataDescription.as<std::string>(), invalid_metric, "_");
110+
uint64_t version = dh->subSpecification;
110111
monitoring.send(Metric{(uint64_t)payload->GetSize(),
111-
fmt::format("table-bytes-{}-{}-created",
112+
fmt::format("table-bytes-{}-{}-{}-created",
112113
origin,
113-
description)}
114+
description,
115+
version)}
114116
.addTag(Key::Subsystem, Value::DPL));
115-
LOGP(detail, "Creating {}MB for table {}/{}.", payload->GetSize() / 1000000., dh->dataOrigin, dh->dataDescription);
117+
LOGP(detail, "Creating {}MB for table {}/{}/{}.", payload->GetSize() / 1000000., dh->dataOrigin, dh->dataDescription, version);
116118
context.updateBytesSent(payload->GetSize());
117119
context.updateMessagesSent(1);
118120
parts.AddPart(std::move(messageRef.header));

0 commit comments

Comments
 (0)