External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-05-07 01:17:37 -02:30
Code Issues Packages Projects Releases Wiki Activity

send test notifications after the transaction closes to avoid a race

Browse Source
This commit is contained in:
Ryan Petrello
2018-09-28 09:43:10 -04:00
parent dc3f81920e
commit 16e89ed081
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
awx/api/views.py
View File

@@ -19,7 +19,7 @@ import six
from django.conf import settings from django.conf import settings
from django.core.exceptions import FieldError, ObjectDoesNotExist from django.core.exceptions import FieldError, ObjectDoesNotExist
from django.db.models import Q, Count, F from django.db.models import Q, Count, F
from django.db import IntegrityError, transaction from django.db import IntegrityError, transaction, connection
from django.shortcuts import get_object_or_404 from django.shortcuts import get_object_or_404
from django.utils.encoding import smart_text from django.utils.encoding import smart_text
from django.utils.safestring import mark_safe from django.utils.safestring import mark_safe
@@ -4960,7 +4960,7 @@ class NotificationTemplateTest(GenericAPIView):
if not notification: if not notification:
return Response({}, status=status.HTTP_400_BAD_REQUEST) return Response({}, status=status.HTTP_400_BAD_REQUEST)
else: else:
send_notifications.delay([notification.id]) connection.on_commit(lambda: send_notifications.delay([notification.id]))
data = OrderedDict() data = OrderedDict()
data['notification'] = notification.id data['notification'] = notification.id
data.update(NotificationSerializer(notification, context=self.get_serializer_context()).to_representation(notification)) data.update(NotificationSerializer(notification, context=self.get_serializer_context()).to_representation(notification))