diff options
author | Trevor Bramwell <tbramwell@linuxfoundation.org> | 2018-11-07 22:05:28 +0000 |
---|---|---|
committer | Gerrit Code Review <gerrit@opnfv.org> | 2018-11-07 22:05:28 +0000 |
commit | 674812a20f6804c287e1355ec8a1adf907798a94 (patch) | |
tree | 8bdfde258ce78b38fe15d84fefdc42b22cdf6441 /dashboard/src/dashboard | |
parent | 027e8b3dfe84300b4c50ea6a39f8dc7e360f479d (diff) | |
parent | 81cfb043f06ab71da7c021a063f80f6df58305cc (diff) |
Merge "Rewrite Notification subsystem"
Diffstat (limited to 'dashboard/src/dashboard')
-rw-r--r-- | dashboard/src/dashboard/tasks.py | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/dashboard/src/dashboard/tasks.py b/dashboard/src/dashboard/tasks.py index 0f7af1c..d4b4189 100644 --- a/dashboard/src/dashboard/tasks.py +++ b/dashboard/src/dashboard/tasks.py @@ -13,18 +13,12 @@ from celery import shared_task from django.utils import timezone from django.db.models import Q from booking.models import Booking -from notifier.manager import * -from notifier.models import * +from notifier.manager import NotificationHandler from api.models import * from resource_inventory.resource_manager import ResourceManager @shared_task -def conjure_aggregate_notifiers(): - NotifyPeriodic.task() - - -@shared_task def booking_poll(): def cleanup_hardware(qs): for hostrelation in qs: @@ -90,6 +84,7 @@ def booking_poll(): cleanup_access(AccessRelation.objects.filter(job=job)) job.complete = True job.save() + NotificationHandler.notify_booking_end(booking) @shared_task |