fix: remove print calls [python]

taskforcesh · May 24, 2024 · e7933df · e7933df
1 parent d3ad53f
commit e7933df
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 9 deletions.
diff --git a/python/bullmq/timer.py b/python/bullmq/timer.py
@@ -17,8 +17,8 @@ async def _job(self):
             while self._ok:
                 await asyncio.sleep(self.interval)
                 await self.callback(*self.args, **self.kwargs)
-        except Exception as ex:
-            print(ex)
+        except Exception:
+            pass
 
     def stop(self):
         self._ok = False

diff --git a/python/bullmq/utils.py b/python/bullmq/utils.py
@@ -10,8 +10,7 @@ def extract_result(job_task):
     except Exception as e:
         if not str(e).startswith('Connection closed by server'):
             # lets use a simple-but-effective error handling:
-            # print error message and ignore the job
-            print("ERROR:", e)
+            # ignore the job
             traceback.print_exc()
 
 def get_parent_key(opts: dict):

diff --git a/python/bullmq/worker.py b/python/bullmq/worker.py
@@ -91,7 +91,6 @@ async def run(self):
 
             except Exception as e:
                 # This should never happen or we will have an endless loop
-                print("ERROR:", e)
                 traceback.print_exc()
                 return
 
@@ -200,13 +199,11 @@ async def processJob(self, job: Job, token: str):
             return
         except Exception as err:
             try:
-                print("Error processing job", err)
                 if not self.forceClosing:
                     await job.moveToFailed(err, token)
 
                 self.emit("failed", job, err)
             except Exception as err:
-                print("Error moving job to failed", err)
                 self.emit("error", err, job)
         finally:
             self.jobs.remove((job, token))
@@ -225,7 +222,6 @@ async def extendLocks(self):
             #    self.emit("error", "could not renew lock for job " + jobId)
 
         except Exception as e:
-            print("Error renewing locks", e)
             traceback.print_exc()
 
     async def runStalledJobsCheck(self):
@@ -238,7 +234,6 @@ async def runStalledJobsCheck(self):
                 self.emit("stalled", jobId)
 
         except Exception as e:
-            print("Error checking stalled jobs", e)
             self.emit('error', e)
 
     async def close(self, force: bool = False):