diff --git a/workers/notificationworker.py b/workers/notificationworker.py index 9c747303f..e922653a8 100644 --- a/workers/notificationworker.py +++ b/workers/notificationworker.py @@ -11,6 +11,7 @@ from data.model import InvalidNotificationException logger = logging.getLogger(__name__) + class NotificationWorker(QueueWorker): def process_queue_item(self, job_details): notification_uuid = job_details['notification_uuid'] diff --git a/workers/queueworker.py b/workers/queueworker.py index 8b76a5a90..dccc5cabb 100644 --- a/workers/queueworker.py +++ b/workers/queueworker.py @@ -23,6 +23,7 @@ class WorkerUnhealthyException(Exception): queue along with another retry. """ pass + class QueueWorker(Worker): def __init__(self, queue, poll_period_seconds=30, reservation_seconds=300, watchdog_period_seconds=60, retry_after_seconds=300):