Skip to content

Commit 718f38e

Browse files
committed
fixup! DPL Analysis: use label+origin as an input binding for tables
1 parent 587d1c9 commit 718f38e

File tree

2 files changed

+33
-33
lines changed

2 files changed

+33
-33
lines changed

Framework/Core/include/Framework/AnalysisHelpers.h

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -380,7 +380,7 @@ template <TableRef R>
380380
constexpr auto tableRef2OutputSpec()
381381
{
382382
return framework::OutputSpec{
383-
framework::OutputLabel{o2::aod::label<R>()},
383+
framework::OutputLabel{o2::aod::binding<R>()},
384384
o2::aod::origin<R>(),
385385
o2::aod::description(o2::aod::signature<R>()),
386386
R.version};
@@ -399,7 +399,7 @@ template <TableRef R>
399399
constexpr auto tableRef2OutputRef()
400400
{
401401
return framework::OutputRef{
402-
o2::aod::label<R>(),
402+
o2::aod::binding<R>(),
403403
R.version};
404404
}
405405
} // namespace o2::soa
@@ -503,12 +503,12 @@ struct OutputForTable {
503503

504504
static OutputSpec const spec()
505505
{
506-
return OutputSpec{OutputLabel{aod::label<table_t::ref>()}, o2::aod::origin<table_t::ref>(), o2::aod::description(o2::aod::signature<table_t::ref>()), table_t::ref.version};
506+
return OutputSpec{OutputLabel{aod::binding<table_t::ref>()}, o2::aod::origin<table_t::ref>(), o2::aod::description(o2::aod::signature<table_t::ref>()), table_t::ref.version};
507507
}
508508

509509
static OutputRef ref()
510510
{
511-
return OutputRef{aod::label<table_t::ref>(), table_t::ref.version};
511+
return OutputRef{aod::binding<table_t::ref>(), table_t::ref.version};
512512
}
513513
};
514514

Framework/Core/test/test_AnalysisTask.cxx

Lines changed: 29 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ struct MTask {
195195
PresliceUnsortedOptional<aod::Collisions> perMcColopt = aod::mccollisionlabel::mcCollisionId;
196196
} foo;
197197
void process(aod::McCollision const&, soa::SmallGroups<soa::Join<aod::Collisions, aod::McCollisionLabels>> const&) {}
198-
};
198+
};\
199199

200200
TEST_CASE("AdaptorCompilation")
201201
{
@@ -205,55 +205,55 @@ TEST_CASE("AdaptorCompilation")
205205
auto task1ng = adaptAnalysisTask<ATask>(*cfgc, TaskName{"test1"});
206206
REQUIRE(task1ng.inputs.size() == 2);
207207
REQUIRE(task1ng.outputs.size() == 1);
208-
REQUIRE(task1ng.inputs[1].binding == std::string("TracksExtension"));
209-
REQUIRE(task1ng.inputs[0].binding == std::string("Tracks"));
210-
REQUIRE(task1ng.outputs[0].binding.value == std::string("FooBars"));
208+
REQUIRE(task1ng.inputs[1].binding == std::string("TracksExtension/DYN"));
209+
REQUIRE(task1ng.inputs[0].binding == std::string("Tracks/AOD"));
210+
REQUIRE(task1ng.outputs[0].binding.value == std::string("FooBars/AOD"));
211211

212212
auto task1ngc = adaptAnalysisTask<ATaskconsumer>(*cfgc);
213213
REQUIRE(task1ngc.inputs.size() == 5);
214-
REQUIRE(task1ngc.inputs[0].binding == "Foos");
215-
REQUIRE(task1ngc.inputs[1].binding == "Roots");
216-
REQUIRE(task1ngc.inputs[2].binding == "B1s");
217-
REQUIRE(task1ngc.inputs[3].binding == "B2s");
218-
REQUIRE(task1ngc.inputs[4].binding == "B3s");
214+
REQUIRE(task1ngc.inputs[0].binding == "Foos/AOD");
215+
REQUIRE(task1ngc.inputs[1].binding == "Roots/AOD");
216+
REQUIRE(task1ngc.inputs[2].binding == "B1s/AOD");
217+
REQUIRE(task1ngc.inputs[3].binding == "B2s/AOD");
218+
REQUIRE(task1ngc.inputs[4].binding == "B3s/AOD");
219219

220220
auto task2 = adaptAnalysisTask<BTask>(*cfgc, TaskName{"test2"});
221221
REQUIRE(task2.inputs.size() == 10);
222-
REQUIRE(task2.inputs[2].binding == "TracksExtension");
223-
REQUIRE(task2.inputs[1].binding == "Tracks");
224-
REQUIRE(task2.inputs[4].binding == "TracksExtra_002Extension");
225-
REQUIRE(task2.inputs[3].binding == "TracksExtra");
226-
REQUIRE(task2.inputs[6].binding == "TracksCovExtension");
227-
REQUIRE(task2.inputs[5].binding == "TracksCov");
228-
REQUIRE(task2.inputs[7].binding == "AmbiguousTracks");
229-
REQUIRE(task2.inputs[8].binding == "Calos");
230-
REQUIRE(task2.inputs[9].binding == "CaloTriggers");
231-
REQUIRE(task2.inputs[0].binding == "Collisions_001");
222+
REQUIRE(task2.inputs[2].binding == "TracksExtension/DYN");
223+
REQUIRE(task2.inputs[1].binding == "Tracks/AOD");
224+
REQUIRE(task2.inputs[4].binding == "TracksExtra_002Extension/DYN");
225+
REQUIRE(task2.inputs[3].binding == "TracksExtra/AOD");
226+
REQUIRE(task2.inputs[6].binding == "TracksCovExtension/DYN");
227+
REQUIRE(task2.inputs[5].binding == "TracksCov/AOD");
228+
REQUIRE(task2.inputs[7].binding == "AmbiguousTracks/AOD");
229+
REQUIRE(task2.inputs[8].binding == "Calos/AOD");
230+
REQUIRE(task2.inputs[9].binding == "CaloTriggers/AOD");
231+
REQUIRE(task2.inputs[0].binding == "Collisions_001/AOD");
232232

233233
auto task3 = adaptAnalysisTask<CTask>(*cfgc, TaskName{"test3"});
234234
REQUIRE(task3.inputs.size() == 3);
235-
REQUIRE(task3.inputs[0].binding == "Collisions_001");
236-
REQUIRE(task3.inputs[1].binding == "Tracks");
237-
REQUIRE(task3.inputs[2].binding == "TracksExtension");
235+
REQUIRE(task3.inputs[0].binding == "Collisions_001/AOD");
236+
REQUIRE(task3.inputs[1].binding == "Tracks/AOD");
237+
REQUIRE(task3.inputs[2].binding == "TracksExtension/DYN");
238238

239239
auto task4 = adaptAnalysisTask<DTask>(*cfgc, TaskName{"test4"});
240240
REQUIRE(task4.inputs.size() == 2);
241-
REQUIRE(task4.inputs[0].binding == "Tracks");
242-
REQUIRE(task4.inputs[1].binding == "TracksExtension");
241+
REQUIRE(task4.inputs[0].binding == "Tracks/AOD");
242+
REQUIRE(task4.inputs[1].binding == "TracksExtension/DYN");
243243

244244
auto task5 = adaptAnalysisTask<ETask>(*cfgc, TaskName{"test5"});
245245
REQUIRE(task5.inputs.size() == 1);
246-
REQUIRE(task5.inputs[0].binding == "FooBars");
246+
REQUIRE(task5.inputs[0].binding == "FooBars/AOD");
247247

248248
auto task6ng = adaptAnalysisTask<FTask>(*cfgc, TaskName{"test6"});
249249
REQUIRE(task6ng.inputs.size() == 1);
250-
REQUIRE(task6ng.inputs[0].binding == "FooBars");
250+
REQUIRE(task6ng.inputs[0].binding == "FooBars/AOD");
251251

252252
auto task7ng = adaptAnalysisTask<GTask>(*cfgc, TaskName{"test7"});
253253
REQUIRE(task7ng.inputs.size() == 3);
254-
REQUIRE(task7ng.inputs[0].binding == "Foos");
255-
REQUIRE(task7ng.inputs[1].binding == "Bars");
256-
REQUIRE(task7ng.inputs[2].binding == "XYZ");
254+
REQUIRE(task7ng.inputs[0].binding == "Foos/AOD");
255+
REQUIRE(task7ng.inputs[1].binding == "Bars/AOD");
256+
REQUIRE(task7ng.inputs[2].binding == "XYZ/AOD");
257257

258258
auto task8ng = adaptAnalysisTask<HTask>(*cfgc, TaskName{"test8"});
259259
REQUIRE(task8ng.inputs.size() == 3);

0 commit comments

Comments
 (0)