File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -133,7 +133,7 @@ def start(self):
133133
134134 self ._running = True
135135 _LOGGER .debug ('Starting SDK Event Task worker' )
136- asyncio .get_running_loop ().create_task (self ._run (), name = "EventsTaskWorker" )
136+ asyncio .get_running_loop ().create_task (self ._run ())
137137
138138 async def stop (self , stop_flag = None ):
139139 """Stop worker."""
Original file line number Diff line number Diff line change @@ -1151,7 +1151,7 @@ async def record_active_and_redundant_factories(*_):
11511151 # Start factory and make assertions
11521152 factory = await get_factory_async ('some_api_key' , config = {'streamingEmabled' : False })
11531153 for task in asyncio .all_tasks ():
1154- if task .get_name () == "EventsTaskWorker " :
1154+ if task .get_coro (). __qualname__ == "EventsTaskAsync._run " :
11551155 task .cancel ()
11561156 try :
11571157 await factory .block_until_ready (3 )
@@ -1204,7 +1204,7 @@ async def record_active_and_redundant_factories(*_):
12041204 # Start factory and make assertions
12051205 factory = await get_factory_async ('some_api_key' , config = {'streamingEmabled' : False })
12061206 for task in asyncio .all_tasks ():
1207- if task .get_name () == "EventsTaskWorker " :
1207+ if task .get_coro (). __qualname__ == "EventsTaskAsync._run " :
12081208 task .cancel ()
12091209 try :
12101210 await factory .block_until_ready (1 )
You can’t perform that action at this time.
0 commit comments