From c9d1400db9d3141b7c1f96c46011f52f3c2f9b1e Mon Sep 17 00:00:00 2001 From: Vanya Belyaev Date: Thu, 25 Apr 2024 10:58:04 +0200 Subject: [PATCH] remove extra prints --- ostap/parallel/parallel_add_branch.py | 6 ------ ostap/parallel/parallel_pathos.py | 9 --------- 2 files changed, 15 deletions(-) diff --git a/ostap/parallel/parallel_add_branch.py b/ostap/parallel/parallel_add_branch.py index 5ba5f240..4e99c802 100644 --- a/ostap/parallel/parallel_add_branch.py +++ b/ostap/parallel/parallel_add_branch.py @@ -103,12 +103,6 @@ def add_new_branch ( chain , wmgr = WorkManager ( silent = not verbose , **kwargs ) trees = ch.split ( max_files = 1 ) - import ostap.parallel.parallel as P - print ( 'PARALLEL' , P.worker , P.WorkManager , P.dill , P.DILL_PY3_issue ) - print ( 'PICKLES/F' , function , P.pickles ( function ) ) - print ( 'PICKLES/B' , branch_name , P.pickles ( branch_name ) ) - print ( 'PICKLES/T' , task , P.pickles ( task ) ) - wmgr.process ( task , trees ) nc = ROOT.TChain ( cname ) diff --git a/ostap/parallel/parallel_pathos.py b/ostap/parallel/parallel_pathos.py index efdea664..89989f23 100644 --- a/ostap/parallel/parallel_pathos.py +++ b/ostap/parallel/parallel_pathos.py @@ -289,15 +289,6 @@ def iexecute ( self , job , jobs_args , progress = False ) : - no summary prin - no merging of results """ - - print ('IEXCUTE', job, type ( job ) , jobs_args ) - import ostap.parallel.parallel as P - print ( 'IEXECUTE/A' , type ( jobs_args), P.pickles ( jobs_args ) ) - print ( 'IEXECUTE/J' , job , type ( job), P.pickles ( job ) ) - - print ( 'BADOBNJECTS' , P.dill.detect.badobjects ( job ) ) - print ( 'BADTYPES' , P.dill.detect.badtypes ( job ) ) - print ( 'ERRORS' , P.dill.detect.errors ( job ) ) with pool_context ( self.pool ) as pool :