File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -541,8 +541,8 @@ o2::framework::ServiceSpec CommonServices::decongestionSpec()
541541 .init = [](ServiceRegistryRef services, DeviceState&, fair::mq::ProgOptions& options) -> ServiceHandle {
542542 auto * decongestion = new DecongestionService ();
543543 for (auto & input : services.get <DeviceSpec const >().inputs ) {
544- if (input.matcher .lifetime == Lifetime::Timeframe) {
545- LOGP (detail, " Found a Timeframe input, we cannot update the oldest possible timeslice" );
544+ if (input.matcher .lifetime == Lifetime::Timeframe || input. matcher . lifetime == Lifetime::QA || input. matcher . lifetime == Lifetime::Sporadic || input. matcher . lifetime == Lifetime::Optional ) {
545+ LOGP (detail, " Found a real data input, we cannot update the oldest possible timeslice when sending messages " );
546546 decongestion->isFirstInTopology = false ;
547547 break ;
548548 }
You can’t perform that action at this time.
0 commit comments