use high-level asyncio funcs

aleph-im · Oct 4, 2023 · c445c01 · c445c01
1 parent 2409a60
commit c445c01
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/aleph/sdk/node/__init__.py b/src/aleph/sdk/node/__init__.py
@@ -354,7 +354,7 @@ async def watch_messages(
 
 class DomainNode(MessageCache, BaseAuthenticatedAlephClient):
     """
-    A Domain Node is a queryable proxy for Aleph Messages that are stored in a database cache and/or in the Aleph
+    A Domain Node is a queryable proxy for aleph.im Messages that are stored in a database cache and/or in the aleph.im
     network.
 
     It synchronizes with the network on a subset of the messages (the "domain") by listening to the network and storing the
@@ -388,7 +388,7 @@ def __init__(
         self.message_types = message_types
 
         # start listening to the network and storing messages in the cache
-        asyncio.get_event_loop().create_task(
+        asyncio.create_task(
             self.listen_to(
                 self.session.watch_messages(
                     channels=self.channels,
@@ -401,7 +401,7 @@ def __init__(
         )
 
         # synchronize with past messages
-        asyncio.get_event_loop().run_until_complete(
+        asyncio.run(
             self.synchronize(
                 channels=self.channels,
                 tags=self.tags,