From 2b59af3808d8b110c2c430349aad9fe825bb3904 Mon Sep 17 00:00:00 2001 From: chris meyers Date: Wed, 26 Feb 2020 11:50:22 -0500 Subject: [PATCH] safely operate in async or sync context --- awx/main/consumers.py | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/awx/main/consumers.py b/awx/main/consumers.py index a14322cb1f..00ffcadbd8 100644 --- a/awx/main/consumers.py +++ b/awx/main/consumers.py @@ -202,13 +202,9 @@ class EventConsumer(AsyncJsonWebsocketConsumer): def run_sync(func): - event_loop = None - try: - event_loop = asyncio.get_event_loop() - except RuntimeError: - event_loop = asyncio.new_event_loop() - asyncio.set_event_loop(event_loop) - return event_loop.run_until_complete(func) + event_loop = asyncio.new_event_loop() + event_loop.run_until_complete(func) + event_loop.close() def _dump_payload(payload):