diff --git a/ostap/frames/tree_reduce.py b/ostap/frames/tree_reduce.py index 1d41e64d..ba605278 100644 --- a/ostap/frames/tree_reduce.py +++ b/ostap/frames/tree_reduce.py @@ -204,7 +204,7 @@ def __init__ ( self , ne = len ( self.__chain ) ff = float ( nb * ne * 100 ) / ( nb0 * ne0 ) - self.__report += '\n# Reduce: (%dx%d) -> (%dx%d) branches x entries => %.1f%% ' % ( nb0 , ne0 , nb , ne , ff ) ) + self.__report += '\n# Reduce: (%dx%d) -> (%dx%d) branches x entries => %.1f%% ' % ( nb0 , ne0 , nb , ne , ff ) self.__report += '\n# Output:%s size:%s' % ( self.__output , fs ) ## self.__report += '\n# %s' % str ( self.__chain ) diff --git a/ostap/parallel/parallel_reduce.py b/ostap/parallel/parallel_reduce.py index c1c712ab..4ceff1c4 100644 --- a/ostap/parallel/parallel_reduce.py +++ b/ostap/parallel/parallel_reduce.py @@ -190,9 +190,8 @@ def reduce ( chain , elif kb : fs = '%.1fkB' % ( float ( fs ) / 1024 ) else : fs = '%sB' % fs - logger.info ( 'Output:%s size:%s' % ( output , fs ) - - + logger.info ( 'Output:%s size:%s' % ( output , fs ) ) + return result ROOT.TTree .preduce = reduce