From 5b4dc9e7ee656a96095b7b46b246dd97308fc74c Mon Sep 17 00:00:00 2001 From: Wayne Witzel III Date: Mon, 13 Nov 2017 10:19:14 -0500 Subject: [PATCH] Disable group sending in consumer (Issue ansible/awx#615) --- awx/main/consumers.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/awx/main/consumers.py b/awx/main/consumers.py index d7abcbff62..1bcf1344f5 100644 --- a/awx/main/consumers.py +++ b/awx/main/consumers.py @@ -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))