Skip to content

Commit a3816d0

Browse files
authored
fixed bug with filter/grouping interaction (#4399)
1 parent 0b0313f commit a3816d0

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

Analysis/Tutorials/src/associatedExample.cxx

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -74,7 +74,8 @@ struct BTask {
7474

7575
struct TTask {
7676
using myCol = soa::Join<aod::Collisions, aod::CollisionsExtra>;
77-
void process(soa::Join<aod::Collisions, aod::CollisionsExtra>::iterator const& col, aod::Tracks const& tracks)
77+
expressions::Filter multfilter = aod::collision::mult > 10;
78+
void process(soa::Filtered<soa::Join<aod::Collisions, aod::CollisionsExtra>>::iterator const& col, aod::Tracks const& tracks)
7879
{
7980
LOGF(INFO, "[direct] ID: %d; %d == %d", col.globalIndex(), col.mult(), tracks.size());
8081
if (tracks.size() > 0) {

Framework/Core/include/Framework/AnalysisTask.h

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -240,7 +240,7 @@ struct AnalysisDataProcessorBuilder {
240240
if (hasIndexTo<std::decay_t<G>>(typename xt::persistent_columns_t{})) {
241241
auto result = o2::framework::sliceByColumn(indexColumnName.c_str(),
242242
x.asArrowTable(),
243-
static_cast<int32_t>(gt.size()),
243+
static_cast<int32_t>(gt.tableSize()),
244244
&groups[index],
245245
&offsets[index]);
246246
if (result.ok() == false) {

0 commit comments

Comments
 (0)