Use asyncio.create_task instead of loop.create_task

mausignald/rpc.py

@@ -50,7 +50,7 @@ class SignaldRPCClient:
             return
 
         initial_connect = self.loop.create_future()
-        self._communicate_task = self.loop.create_task(self._communicate_forever(initial_connect))
+        self._communicate_task = asyncio.create_task(self._communicate_forever(initial_connect))
         await initial_connect
 
     async def _communicate_forever(self, initial_connect: Optional[asyncio.Future] = None) -> None:
@@ -62,7 +62,7 @@ class SignaldRPCClient:
                 await asyncio.sleep(5)
                 continue
 
-            read_loop = self.loop.create_task(self._try_read_loop())
+            read_loop = asyncio.create_task(self._try_read_loop())
             await self._run_rpc_handler(CONNECT_EVENT, {})
 
             if initial_connect:
@@ -136,7 +136,7 @@ class SignaldRPCClient:
 
         req_id = req.get("id")
         if req_id is None:
-            self.loop.create_task(self._run_rpc_handler(req_type, req))
+            asyncio.create_task(self._run_rpc_handler(req_type, req))
         else:
             self._run_response_handlers(UUID(req_id), req_type, req)
 

mautrix_signal/puppet.py

@@ -178,7 +178,7 @@ class Puppet(DBPuppet, BasePuppet):
                 update = await self._update_avatar(info.avatar) or update
             if update:
                 await self.update()
-                self.loop.create_task(self._update_portal_meta())
+                asyncio.create_task(self._update_portal_meta())
 
     @staticmethod
     def fmt_phone(number: str) -> str:

mautrix_signal/signal.py

@@ -143,7 +143,7 @@ class SignalHandler(SignaldClient):
         async for user in u.User.all_logged_in():
             # TODO report errors to user?
             if await self.subscribe(user.username):
-                self.loop.create_task(user.sync())
+                asyncio.create_task(user.sync())
 
     async def stop(self) -> None:
         await self.disconnect()

mautrix_signal/user.py

@@ -107,7 +107,7 @@ class User(DBUser, BaseUser):
         self._add_to_cache()
         await self.update()
         await self.bridge.signal.subscribe(self.username)
-        self.loop.create_task(self.sync())
+        asyncio.create_task(self.sync())
 
     def on_listen(self, evt: ListenEvent) -> None:
         if evt.action == ListenAction.STARTED: