Skip to content

Commit bd8085b

Browse files
committed
[QC-1292] Missing run number in logs from BookkeepingSink
- added initialization of IL - set the run number whenever we get one
1 parent 842accf commit bd8085b

File tree

2 files changed

+10
-1
lines changed

2 files changed

+10
-1
lines changed

Framework/include/QualityControl/BookkeepingQualitySink.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ class BookkeepingQualitySink : public framework::Task
4040
BookkeepingQualitySink(const std::string& grpcUri, Provenance, SendCallback sendCallback = send);
4141

4242
void run(framework::ProcessingContext&) override;
43+
void init(framework::InitContext& iCtx) override;
4344

4445
void endOfStream(framework::EndOfStreamContext& context) override;
4546
void stop() override;

Framework/src/BookkeepingQualitySink.cxx

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,11 @@
2020
#include <Framework/CompletionPolicyHelpers.h>
2121
#include <Framework/DeviceSpec.h>
2222
#include <DataFormatsQualityControl/QualityControlFlagCollection.h>
23-
#include "QualityControl/Bookkeeping.h"
2423
#include "QualityControl/QualitiesToFlagCollectionConverter.h"
2524
#include "QualityControl/QualityObject.h"
2625
#include "QualityControl/QcInfoLogger.h"
26+
#include "QualityControl/runnerUtils.h"
27+
2728
#include <BookkeepingApi/QcFlagServiceClient.h>
2829
#include <BookkeepingApi/BkpClientFactory.h>
2930
#include <CCDB/BasicCCDBManager.h>
@@ -42,6 +43,12 @@ void BookkeepingQualitySink::customizeInfrastructure(std::vector<framework::Comp
4243
policies.emplace_back(CompletionPolicyHelpers::consumeWhenAny("BookkeepingQualitySinkCompletionPolicy", matcher));
4344
}
4445

46+
void BookkeepingQualitySink::init(framework::InitContext& iCtx)
47+
{
48+
initInfologger(iCtx, {}, "bkqsink/", "");
49+
ILOG(Info, Devel) << "Initialized BookkeepingQualitySink" << ENDM;
50+
}
51+
4552
void BookkeepingQualitySink::send(const std::string& grpcUri, const BookkeepingQualitySink::FlagsMap& flags, Provenance provenance)
4653
{
4754
auto bkpClient = o2::bkp::api::BkpClientFactory::create(grpcUri);
@@ -70,6 +77,7 @@ void BookkeepingQualitySink::send(const std::string& grpcUri, const BookkeepingQ
7077
}
7178
if (!runNumber.has_value()) {
7279
runNumber = flagCollection->getRunNumber();
80+
QcInfoLogger::setRun(runNumber.value());
7381
}
7482
if (!passName.has_value()) {
7583
passName = flagCollection->getPassName();

0 commit comments

Comments
 (0)