Fix typo in datasource (#51)

dipdup-io · May 24, 2021 · 30c51b2 · 30c51b2
1 parent 3659c2e
commit 30c51b2
Showing 1 changed file with 4 additions and 3 deletions.
diff --git 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):