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

removed unused imports. fix exception message

Browse Source 
Signed-off-by: jessicamack <jmack@redhat.com>
This commit is contained in:
jessicamack
2023-03-27 11:20:20 -04:00
committed by Hao Liu
parent 24cbf39a93
commit 57d009199d
2 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
awx/main/tasks/system.py
View File

@@ -61,7 +61,6 @@ from awx.main.utils.common import (
from awx.main.utils.reload import stop_local_services from awx.main.utils.reload import stop_local_services
from awx.main.utils.pglock import advisory_lock 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.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.consumers import emit_channel_notification
from awx.main import analytics from awx.main import analytics

4
awx/main/wsrelay.py
View File

@@ -4,10 +4,8 @@ import asyncio
import aiohttp import aiohttp
from aiohttp import client_exceptions from aiohttp import client_exceptions
from asgiref.sync import sync_to_async
from channels.layers import get_channel_layer from channels.layers import get_channel_layer
from channels.db import database_sync_to_async
from django.conf import settings from django.conf import settings
from django.apps import apps from django.apps import apps
@@ -240,7 +238,7 @@ class WebSocketRelayManager(object):
except Exception as e: except Exception as e:
# This catch-all is the same as the one above. asyncio will eat the exception # This catch-all is the same as the one above. asyncio will eat the exception
# but we want to know about it. # but we want to know about it.
logger.exception(f"pg_consumer exception") logger.exception(f"pg_consumer exception: {e}")
async def run(self): async def run(self):
event_loop = asyncio.get_running_loop() event_loop = asyncio.get_running_loop()