diff --git a/awx/main/tasks/system.py b/awx/main/tasks/system.py index 6edf78ff8d..a83dad5ccc 100644 --- a/awx/main/tasks/system.py +++ b/awx/main/tasks/system.py @@ -61,7 +61,6 @@ from awx.main.utils.common import ( from awx.main.utils.reload import stop_local_services from awx.main.utils.pglock import advisory_lock -from awx.main.utils.external_logging import send_pg_notify from awx.main.tasks.receptor import get_receptor_ctl, worker_info, worker_cleanup, administrative_workunit_reaper, write_receptor_config from awx.main.consumers import emit_channel_notification from awx.main import analytics diff --git a/awx/main/wsrelay.py b/awx/main/wsrelay.py index 3260182b7c..6baa2954b2 100644 --- a/awx/main/wsrelay.py +++ b/awx/main/wsrelay.py @@ -4,10 +4,8 @@ import asyncio import aiohttp from aiohttp import client_exceptions -from asgiref.sync import sync_to_async from channels.layers import get_channel_layer -from channels.db import database_sync_to_async from django.conf import settings from django.apps import apps @@ -240,7 +238,7 @@ class WebSocketRelayManager(object): except Exception as e: # This catch-all is the same as the one above. asyncio will eat the exception # but we want to know about it. - logger.exception(f"pg_consumer exception") + logger.exception(f"pg_consumer exception: {e}") async def run(self): event_loop = asyncio.get_running_loop()