From 2a48977bf40dd0d8c040dad9f06d095681d0f8ba Mon Sep 17 00:00:00 2001 From: Lev Gorodetskiy Date: Mon, 24 May 2021 21:18:43 +0300 Subject: [PATCH] Fix typo in datasource --- src/dipdup/datasources/tzkt/datasource.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/dipdup/datasources/tzkt/datasource.py b/src/dipdup/datasources/tzkt/datasource.py index a74ff17cd..2c5e4f64c 100644 --- a/src/dipdup/datasources/tzkt/datasource.py +++ b/src/dipdup/datasources/tzkt/datasource.py @@ -100,11 +100,12 @@ def submit(self, fn, *args, **kwargs): async def run(self): while True: + await asyncio.sleep(0.1) try: coro = self._queue.popleft() await coro except IndexError: - await asyncio.sleep(0.1) + pass except asyncio.CancelledError: return @@ -369,8 +370,8 @@ async def start(self): if not rest_only: self._logger.info('Starting websocket client') await asyncio.gather( - await self._get_client().start(), - await self._callback_executor.run(), + self._get_client().start(), + self._callback_executor.run(), ) async def stop(self):