From f9b8a69f7b496aaddefa2fced503cd6cefa60ed8 Mon Sep 17 00:00:00 2001 From: Ryan Petrello Date: Wed, 1 Apr 2020 08:03:59 -0400 Subject: [PATCH] remove some unused code from the redis rewrite --- awx/main/consumers.py | 25 ------------------------- 1 file changed, 25 deletions(-) diff --git a/awx/main/consumers.py b/awx/main/consumers.py index 41d60ad1c4..dc8f41e48e 100644 --- a/awx/main/consumers.py +++ b/awx/main/consumers.py @@ -213,31 +213,6 @@ def _dump_payload(payload): return None -async def emit_channel_notification_async(group, payload): - from awx.main.wsbroadcast import wrap_broadcast_msg # noqa - - payload_dumped = _dump_payload(payload) - if payload_dumped is None: - return - - channel_layer = get_channel_layer() - await channel_layer.group_send( - group, - { - "type": "internal.message", - "text": payload_dumped - }, - ) - - await channel_layer.group_send( - settings.BROADCAST_WEBSOCKET_GROUP_NAME, - { - "type": "internal.message", - "text": wrap_broadcast_msg(group, payload_dumped), - }, - ) - - def emit_channel_notification(group, payload): from awx.main.wsbroadcast import wrap_broadcast_msg # noqa