From aac6984ec3d100f604eccaa9c4a9ee612280f392 Mon Sep 17 00:00:00 2001 From: Daniel Welch Date: Thu, 30 Mar 2017 22:02:31 -0400 Subject: [PATCH] replace rollbar reporting with generic error_reporter reporting in cluster.py --- django_q/cluster.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/django_q/cluster.py b/django_q/cluster.py index 3810b15..ba50bcc 100644 --- a/django_q/cluster.py +++ b/django_q/cluster.py @@ -30,7 +30,7 @@ from django import db import signing 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.status import Stat, Status 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) except (ValueError, ImportError, AttributeError) as e: result = (e, False) - if rollbar: - rollbar.report_exc_info() + if error_reporter: + error_reporter.report() # We're still going if not result: db.close_old_connections() @@ -380,8 +380,8 @@ def worker(task_queue, result_queue, timer, timeout=Conf.TIMEOUT): result = (res, True) except Exception as e: result = ('{}'.format(e), False) - if rollbar: - rollbar.report_exc_info() + if error_reporter: + error_reporter.report() # Process result task['result'] = result[0] task['success'] = result[1]