fix a bug introduced in rebase

This commit is contained in:
Ryan Petrello 2019-08-27 15:51:04 -04:00
parent b9f75ecad7
commit 23f75cf74a
No known key found for this signature in database
GPG Key ID: F2AA5F2122351777

View File

@ -485,5 +485,6 @@ class JobNotificationMixin(object):
def send_it(local_nt=nt, local_subject=notification_subject, local_body=notification_body):
def _func():
send_notifications.delay([local_nt.generate_notification(local_subject, local_body).id],
job_id=self.id)
return _func
connection.on_commit(send_it())