Skip to content

Commit 8d00eb5

Browse files
committed
DPL: handle case of list as first field of the dataset
1 parent 7b51768 commit 8d00eb5

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

Framework/AnalysisSupport/src/TTreePlugin.cxx

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -627,13 +627,13 @@ arrow::Result<arrow::RecordBatchGenerator> TTreeFileFormat::ScanBatchesAsync(
627627
throw runtime_error_f("Cannot find physical field associated to %s. Possible fields: %s",
628628
dataset_field->name().c_str(), physical_schema->ToString().c_str());
629629
}
630-
if (physicalFieldIdx > 1 && physical_schema->field(physicalFieldIdx - 1)->name().ends_with("_size")) {
630+
if (physicalFieldIdx > 0 && physical_schema->field(physicalFieldIdx - 1)->name().ends_with("_size")) {
631631
O2_SIGNPOST_EVENT_EMIT(root_arrow_fs, tid, "Generator", "Field %{public}s has sizes in %{public}s.", dataset_field->name().c_str(),
632632
physical_schema->field(physicalFieldIdx - 1)->name().c_str());
633633
mappings.push_back({physicalFieldIdx, physicalFieldIdx - 1, fi});
634634
opsCount += 2;
635635
} else {
636-
if (physicalFieldIdx > 1) {
636+
if (physicalFieldIdx > 0) {
637637
O2_SIGNPOST_EVENT_EMIT(root_arrow_fs, tid, "Generator", "Field %{public}s previous field is %{public}s.", dataset_field->name().c_str(),
638638
physical_schema->field(physicalFieldIdx - 1)->name().c_str());
639639
}

0 commit comments

Comments
 (0)