make progress to logger object optional

job_pool/job_pool.py

@@ -65,6 +65,7 @@ def __init__(
         queue: Optional[multiprocessing.Queue] = None,
         timeout: int = 10000,
         maxtasksperchild: Optional[int] = None,
+        write_progress_to_logger: bool = False,
     ):
         """Creates a JobPool object
 
@@ -84,6 +85,7 @@ def __init__(
         """
         self.timeout = timeout
         self.maxtasksperchild = maxtasksperchild
+        self.write_progress_to_logger = write_progress_to_logger
 
         if not queue and multiprocessing.current_process().name != "MainProcess":
             queue = multiprocessing.Queue()
@@ -106,7 +108,9 @@ def applyAsync(self, f, fargs, *args, **kwargs):
     def checkPool(self, printProgressEvery: int = -1):
         try:
             outputs = list()
-            tqdm_out = TqdmToLogger(logger, level=logging.INFO)
+            tqdm_out = None
+            if self.write_progress_to_logger:
+                tqdm_out = TqdmToLogger(logger, level=logging.INFO)
             for res in tqdm(
                 self.results,
                 file=tqdm_out,