diff --git a/src/aleph/sdk/node/__init__.py b/src/aleph/sdk/node/__init__.py index a001ea01..5bab9cf8 100644 --- 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,