Skip to content

Commit

Permalink
DPL: fix adjustment of spawnerInputs (#13713)
Browse files Browse the repository at this point in the history
  • Loading branch information
ktf authored Nov 19, 2024
1 parent 8aba4a9 commit 7c8b70e
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions Framework/Core/src/ArrowSupport.cxx
Original file line number Diff line number Diff line change
Expand Up @@ -472,19 +472,19 @@ o2::framework::ServiceSpec ArrowSupport::arrowBackendSpec()
}
std::sort(ac.requestedDYNs.begin(), ac.requestedDYNs.end(), inputSpecLessThan);
std::sort(ac.providedDYNs.begin(), ac.providedDYNs.end(), outputSpecLessThan);
std::vector<InputSpec> spawnerInputs;
ac.spawnerInputs.clear();
for (auto& input : ac.requestedDYNs) {
if (std::none_of(ac.providedDYNs.begin(), ac.providedDYNs.end(), [&input](auto const& x) { return DataSpecUtils::match(input, x); })) {
spawnerInputs.emplace_back(input);
ac.spawnerInputs.emplace_back(input);
}
}
// recreate inputs and outputs
spawner->outputs.clear();
spawner->inputs.clear();
// replace AlgorithmSpec
// FIXME: it should be made more generic, so it does not need replacement...
spawner->algorithm = readers::AODReaderHelpers::aodSpawnerCallback(spawnerInputs);
AnalysisSupportHelpers::addMissingOutputsToSpawner({}, spawnerInputs, ac.requestedAODs, *spawner);
spawner->algorithm = readers::AODReaderHelpers::aodSpawnerCallback(ac.spawnerInputs);
AnalysisSupportHelpers::addMissingOutputsToSpawner({}, ac.spawnerInputs, ac.requestedAODs, *spawner);
}

if (writer != workflow.end()) {
Expand Down

0 comments on commit 7c8b70e

Please sign in to comment.