Skip to content

Commit 632a16c

Browse files
authored
Forward messages with empty payloads (QC-401) (#474)
1 parent 8cf4a87 commit 632a16c

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

Framework/src/TaskRunner.cxx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -159,7 +159,7 @@ CompletionPolicy::CompletionOp TaskRunner::completionPolicyCallback(o2::framewor
159159
CompletionPolicy::CompletionOp action = CompletionPolicy::CompletionOp::Wait;
160160

161161
for (auto& input : inputs) {
162-
if (input.header == nullptr || input.payload == nullptr) {
162+
if (input.header == nullptr) {
163163
continue;
164164
}
165165

@@ -263,7 +263,7 @@ std::tuple<bool /*data ready*/, bool /*timer ready*/> TaskRunner::validateInputs
263263
bool timerReady = false;
264264

265265
for (auto& input : inputs) {
266-
if (input.header != nullptr && input.payload != nullptr) {
266+
if (input.header != nullptr) {
267267

268268
const auto* dataHeader = get<DataHeader*>(input.header);
269269
assert(dataHeader);

0 commit comments

Comments
 (0)