File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -105,7 +105,13 @@ def _initialize_webhook_server(self):
105105 self .driver .register_webhook_server (self .webhook_server )
106106 # Schedule the queue loop to the current event loop so that it starts together
107107 # with self.init_websocket.
108- asyncio .get_event_loop ().create_task (
108+ try :
109+ loop = asyncio .get_running_loop ()
110+ except RuntimeError :
111+ loop = asyncio .new_event_loop ()
112+ asyncio .set_event_loop (loop )
113+
114+ loop .create_task (
109115 self .event_handler ._check_queue_loop (self .webhook_server .event_queue )
110116 )
111117
Original file line number Diff line number Diff line change @@ -60,7 +60,13 @@ async def start(self):
6060 self .running = True
6161
6262 # Schedule the response awaiting function to the same loop as the web server
63- asyncio .get_event_loop ().create_task (self ._obtain_responses_loop ())
63+ try :
64+ loop = asyncio .get_running_loop ()
65+ except RuntimeError :
66+ loop = asyncio .new_event_loop ()
67+ asyncio .set_event_loop (loop )
68+
69+ loop .create_task (self ._obtain_responses_loop ())
6470
6571 async def stop (self ):
6672 await self .app_runner .cleanup ()
You can’t perform that action at this time.
0 commit comments