Skip to content

Commit f38db19

Browse files
committed
use better criterion to add arrow support service
1 parent ddcdd1f commit f38db19

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Framework/Core/src/runDataProcessing.cxx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3010,8 +3010,8 @@ int doMain(int argc, char** argv, o2::framework::WorkflowSpec const& workflow,
30103010
ServiceSpecs driverServices = ServiceSpecHelpers::filterDisabled(CommonDriverServices::defaultServices(), driverServicesOverride);
30113011
// We insert the hash for the internal devices.
30123012
WorkflowHelpers::injectServiceDevices(physicalWorkflow, configContext);
3013-
auto reader = std::find_if(physicalWorkflow.begin(), physicalWorkflow.end(), [](DataProcessorSpec& spec) { return spec.name == "internal-dpl-aod-reader"; });
3014-
if (reader != physicalWorkflow.end()) {
3013+
auto& dec = configContext.services().get<DanglingEdgesContext>();
3014+
if (!(dec.requestedAODs.empty() && dec.requestedDYNs.empty() && dec.requestedIDXs.empty() && dec.requestedTIMs.empty())) {
30153015
driverServices.push_back(ArrowSupport::arrowBackendSpec());
30163016
}
30173017
for (auto& service : driverServices) {

0 commit comments

Comments
 (0)