External-Mirrors/awx
2
0
Fork 0
mirror of https://github.com/ansible/awx.git synced 2026-01-13 11:00:03 -03:30
Code Issues Packages Projects Releases Wiki Activity

Disable group sending in consumer (Issue ansible/awx#615)

Browse Source
This commit is contained in:
Wayne Witzel III 2017-11-13 10:19:14 -05:00
parent f118e27047
commit 5b4dc9e7ee
No known key found for this signature in database
GPG Key ID: B4F07BDC564D6301
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
awx/main/consumers.py
View File

@ -7,7 +7,7 @@ from channels.sessions import channel_session
from channels.handler import AsgiRequest
from django.conf import settings
from django.core.serializers.json import DjangoJSONEncoder
#from django.core.serializers.json import DjangoJSONEncoder
from django.contrib.auth.models import User
from awx.main.models.organization import AuthToken
@ -94,6 +94,8 @@ def ws_receive(message):
def emit_channel_notification(group, payload):
try:
Group(group).send({"text": json.dumps(payload, cls=DjangoJSONEncoder)})
# FIXME: Currently broken with asgi_rabbitmq as a ChannelLayer
#Group(group).send({"text": json.dumps(payload, cls=DjangoJSONEncoder)})
logger.warning("Group sending is currently disabled. Would have sent the following message\nChannel: {0}, Payload: {1}".format(group, payload))
except ValueError:
logger.error("Invalid payload emitting channel {} on topic: {}".format(group, payload))