Skip to content

Commit e1052ca

Browse files
authored
Fix CompletionPolicy for BookkeepingQualitySink (#2465)
A label for matching the correct CompletionPolicy in BookkeepingQualitySink was missing. This was causing it to wait indefinitely for matching inputs for the same timeslice if QOs from different Data Processors were requested. The change allows BookkeepingQualitySink to consume the inputs immediatelly and pass them to any other process which may also need them.
1 parent 3bc5b31 commit e1052ca

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Framework/src/InfrastructureGenerator.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -810,7 +810,7 @@ void InfrastructureGenerator::generateBookkeepingQualitySink(WorkflowSpec& workf
810810
.algorithm = adaptFromTask<quality_control::core::BookkeepingQualitySink>(
811811
infrastructureSpec.common.bookkeepingUrl,
812812
core::toEnum(infrastructureSpec.common.activityProvenance)),
813-
.labels = { { "resilient" } }
813+
.labels = { { "resilient" }, BookkeepingQualitySink::getLabel() }
814814
};
815815
workflow.emplace_back(std::move(sinkDataProcessor));
816816
}

0 commit comments

Comments
 (0)