Revert "Replace asyncio.ensure_future() with asyncio.create_task()"
This reverts commit bac6a4b2bf.
This is not actually something we want
This commit is contained in:
@@ -622,7 +622,7 @@ class SlixTest(unittest.TestCase):
|
||||
|
||||
def wait_for_send_queue(self):
|
||||
loop = asyncio.get_event_loop()
|
||||
future = asyncio.create_task(self.xmpp.run_filters(), loop=loop)
|
||||
future = asyncio.ensure_future(self.xmpp.run_filters(), loop=loop)
|
||||
queue = self.xmpp.waiting_queue
|
||||
loop.run_until_complete(queue.join())
|
||||
future.cancel()
|
||||
|
||||
Reference in New Issue
Block a user