fork/django-q2
1
0
Fork 0
mirror of https://github.com/django-q2/django-q2.git synced 2026-10-06 13:18:12 +08:00
Code Issues Packages Projects Releases Wiki Activity

replace rollbar reporting with generic error_reporter reporting in cluster.py

Browse Source
This commit is contained in:
Daniel Welch
2017-03-30 22:02:31 -04:00
parent 9e97d48012
commit aac6984ec3
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
django_q/cluster.py
+5 -5
View File
@@ -30,7 +30,7 @@ from django import db
import signing import signing
import tasks import tasks
from django_q.conf import Conf, logger, psutil, get_ppid, rollbar from django_q.conf import Conf, logger, psutil, get_ppid, error_reporter
from django_q.models import Task, Success, Schedule from django_q.models import Task, Success, Schedule
from django_q.status import Stat, Status from django_q.status import Stat, Status
from django_q.brokers import get_broker from django_q.brokers import get_broker
@@ -368,8 +368,8 @@ def worker(task_queue, result_queue, timer, timeout=Conf.TIMEOUT):
f = getattr(m, func) f = getattr(m, func)
except (ValueError, ImportError, AttributeError) as e: except (ValueError, ImportError, AttributeError) as e:
result = (e, False) result = (e, False)
if rollbar: if error_reporter:
rollbar.report_exc_info() error_reporter.report()
# We're still going # We're still going
if not result: if not result:
db.close_old_connections() db.close_old_connections()
@@ -380,8 +380,8 @@ def worker(task_queue, result_queue, timer, timeout=Conf.TIMEOUT):
result = (res, True) result = (res, True)
except Exception as e: except Exception as e:
result = ('{}'.format(e), False) result = ('{}'.format(e), False)
if rollbar: if error_reporter:
rollbar.report_exc_info() error_reporter.report()
# Process result # Process result
task['result'] = result[0] task['result'] = result[0]
task['success'] = result[1] task['success'] = result[1]