Fix bot client tests

Author: linuxdaemon

cloudbot/bot.py

@@ -419,4 +419,6 @@ def add_hook(hook, _event):
         tasks.sort(key=lambda t: t[0].priority)
 
         for _hook, _event in tasks:
-            async_util.wrap_future(self.plugin_manager.launch(_hook, _event))
+            async_util.wrap_future(
+                self.plugin_manager.launch(_hook, _event), loop=self.loop
+            )

tests/core_tests/irc_client_test.py

@@ -46,7 +46,7 @@ def wait_tasks(self, conn, cancel=False):
                 task.cancel()
 
         try:
-            conn.loop.run_until_complete(asyncio.gather(*tasks))
+            conn.loop.run_until_complete(asyncio.gather(*tasks, loop=conn.loop))
         except CancelledError:
             if not cancel:
                 raise  # pragma: no cover
@@ -61,7 +61,7 @@ def make_proto(self):
         conn.loop = asyncio.get_event_loop_policy().new_event_loop()
         out = []
 
-        async def func(e):
+        def func(e):
             out.append(self._filter_event(e))
 
         conn.bot.process = func
@@ -133,6 +133,8 @@ def test_broken_line_doesnt_interrupt(self, caplog):
 
         self.wait_tasks(conn)
 
+        assert len(out) == 2
+
         assert out == [
             {
                 "chan": "server\x02.host",