@@ -715,16 +715,16 @@ o2::framework::ServiceSpec
715715 O2_SIGNPOST_EVENT_EMIT (data_processor_context, cid, " oldest_possible_timeslice" , " Queueing oldest possible timeslice %" PRIu64 " propagation for execution." ,
716716 (uint64_t )oldestPossibleOutput.timeslice .value );
717717 AsyncQueueHelpers::post (
718- queue, AsyncTask{ .timeslice = TimesliceId{oldestPossibleTimeslice},
719- .id = decongestion.oldestPossibleTimesliceTask ,
720- .debounce = -1 , .callback = decongestionCallback}
721- .user <DecongestionContext>(DecongestionContext{.ref = services, .oldestPossibleOutput = oldestPossibleOutput}));
718+ queue, AsyncTask{.timeslice = TimesliceId{oldestPossibleTimeslice},
719+ .id = decongestion.oldestPossibleTimesliceTask ,
720+ .debounce = -1 ,
721+ .callback = decongestionCallback}
722+ .user <DecongestionContext>(DecongestionContext{.ref = services, .oldestPossibleOutput = oldestPossibleOutput}));
722723
723724 if (decongestion.orderedCompletionPolicyActive ) {
724725 AsyncQueueHelpers::post (
725- queue, AsyncTask{.timeslice = TimesliceId{oldestPossibleOutput.timeslice .value },.id = decongestion.oldestPossibleTimesliceTask , .debounce = -1 ,
726- .callback = decongestionCallbackOrdered}
727- .user <DecongestionContext>({.ref = services, .oldestPossibleOutput = oldestPossibleOutput}));
726+ queue, AsyncTask{.timeslice = TimesliceId{oldestPossibleOutput.timeslice .value }, .id = decongestion.oldestPossibleTimesliceTask , .debounce = -1 , .callback = decongestionCallbackOrdered}
727+ .user <DecongestionContext>({.ref = services, .oldestPossibleOutput = oldestPossibleOutput}));
728728 } },
729729 .kind = ServiceKind::Serial};
730730}
0 commit comments