diff --git a/servicex_analysis_utils/materialization.py b/servicex_analysis_utils/materialization.py index 167f2ee..a75f496 100644 --- a/servicex_analysis_utils/materialization.py +++ b/servicex_analysis_utils/materialization.py @@ -84,10 +84,13 @@ def to_awk(deliver_dict, dask=False, iterator=False, **kwargs): if iterator == True: awk_arrays[sample] = iterators # return iterators else: - awk_arrays[sample] = ak.concatenate( - list(iterators) - ) # return array - + arrays = list(iterators) + if arrays: + awk_arrays[sample] = ak.concatenate(arrays) + else: + raise RuntimeError( + f"No arrays yielded for sample {sample}. Check file content or TTree name." + ) else: # file is parquet awk_arrays[sample] = ak.from_parquet(paths, **kwargs)