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+
4552void BookkeepingQualitySink::send (const std::string& grpcUri, const BookkeepingQualitySink::FlagsMap& flags, Provenance provenance)
4653{
4754 auto & bkpClient = o2::quality_control::core::Bookkeeping::getInstance ();
@@ -69,6 +76,7 @@ void BookkeepingQualitySink::send(const std::string& grpcUri, const BookkeepingQ
6976 }
7077 if (!runNumber.has_value ()) {
7178 runNumber = flagCollection->getRunNumber ();
79+ QcInfoLogger::setRun (runNumber.value ());
7280 }
7381 if (!passName.has_value ()) {
7482 passName = flagCollection->getPassName ();
0 commit comments