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):