diff --git a/subiquity/common/errorreport.py b/subiquity/common/errorreport.py
index fbdc8e11..31695951 100644
--- a/subiquity/common/errorreport.py
+++ b/subiquity/common/errorreport.py
@@ -174,7 +174,7 @@ class ErrorReport(metaclass=urwid.MetaSignals):
                 _bg_add_info()
                 context.description = "written to " + self.path
         else:
-            self._info_task = asyncio.get_running_loop().create_task(add_info())
+            self._info_task = asyncio.create_task(add_info())
 
     async def load(self):
         with self._context.child("load"):
diff --git a/subiquity/models/subiquity.py b/subiquity/models/subiquity.py
index fad99e51..75e9ae9b 100644
--- a/subiquity/models/subiquity.py
+++ b/subiquity/models/subiquity.py
@@ -268,7 +268,7 @@ class SubiquityModel:
 
     async def wait_confirmation(self):
         if self._confirmation_task is None:
-            self._confirmation_task = asyncio.get_running_loop().create_task(
+            self._confirmation_task = asyncio.create_task(
                 self._confirmation.wait())
         try:
             await self._confirmation_task
diff --git a/subiquitycore/pubsub.py b/subiquitycore/pubsub.py
index 62e5bf80..df40cb76 100644
--- a/subiquitycore/pubsub.py
+++ b/subiquitycore/pubsub.py
@@ -36,5 +36,4 @@ class MessageHub:
                 await v
 
     def broadcast(self, channel, *args, **kwargs):
-        loop = asyncio.get_running_loop()
-        return loop.create_task(self.abroadcast(channel, *args, **kwargs))
+        return asyncio.create_task(self.abroadcast(channel, *args, **kwargs))