fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-07 19:48:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

Log exceptions with logger.exception (#42)

Browse Source 
Co-authored-by: Andreas Bok Andersen <andreas.bokandersen@glooko.com>
This commit is contained in:
Andreas Andersen
2022-11-30 15:03:20 +01:00
committed by GitHub
co-authored by Andreas Bok Andersen
parent 3c0c32758d
commit 2566955782
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/cluster.py
+2 -2
View File
@@ -367,7 +367,7 @@ def pusher(task_queue: Queue, event: Event, broker: Broker = None):
try: try:
task_set = broker.dequeue() task_set = broker.dequeue()
except Exception as e: except Exception as e:
logger.error(e, traceback.format_exc()) logger.exception("Failed to pull task from broker")
# broker probably crashed. Let the sentinel handle it. # broker probably crashed. Let the sentinel handle it.
sleep(10) sleep(10)
break break
@@ -378,7 +378,7 @@ def pusher(task_queue: Queue, event: Event, broker: Broker = None):
try: try:
task = SignedPackage.loads(task[1]) task = SignedPackage.loads(task[1])
except (TypeError, BadSignature) as e: except (TypeError, BadSignature) as e:
logger.error(e, traceback.format_exc()) logger.exception("Failed to push task to queue")
broker.fail(ack_id) broker.fail(ack_id)
continue continue
task["ack_id"] = ack_id task["ack_id"] = ack_id