We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 61b288c commit 5edce72Copy full SHA for 5edce72
1 file changed
Framework/Core/src/ExternalFairMQDeviceProxy.cxx
@@ -536,6 +536,7 @@ InjectorFunction dplModelAdaptor(std::vector<OutputSpec> const& filterSpecs, DPL
536
timingInfo.runNumber = dh->runNumber;
537
timingInfo.tfCounter = dh->tfCounter;
538
LOG(debug) << msgidx << ": " << DataSpecUtils::describe(OutputSpec{dh->dataOrigin, dh->dataDescription, dh->subSpecification}) << " part " << dh->splitPayloadIndex << " of " << dh->splitPayloadParts << " payload " << parts.At(msgidx + 1)->GetSize();
539
+ //
540
if (DefaultsHelpers::deploymentMode() != DeploymentMode::FST && (dh->runNumber == 0 || (dh->tfCounter == 0 && dh->dataDescription.as<std::string>() != "EOS") || (fmqRunNumber > 0 && fmqRunNumber != dh->runNumber))) {
541
LOG(error) << "INVALID runNumber / tfCounter: runNumber " << dh->runNumber
542
<< ", tfCounter " << dh->tfCounter << ", FMQ runNumber " << fmqRunNumber
0 commit comments