Skip to content

Commit 30c51b2

Browse files
Fix typo in datasource (#51)
1 parent 3659c2e commit 30c51b2

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

src/dipdup/datasources/tzkt/datasource.py

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -100,11 +100,12 @@ def submit(self, fn, *args, **kwargs):
100100

101101
async def run(self):
102102
while True:
103+
await asyncio.sleep(0.1)
103104
try:
104105
coro = self._queue.popleft()
105106
await coro
106107
except IndexError:
107-
await asyncio.sleep(0.1)
108+
pass
108109
except asyncio.CancelledError:
109110
return
110111

@@ -369,8 +370,8 @@ async def start(self):
369370
if not rest_only:
370371
self._logger.info('Starting websocket client')
371372
await asyncio.gather(
372-
await self._get_client().start(),
373-
await self._callback_executor.run(),
373+
self._get_client().start(),
374+
self._callback_executor.run(),
374375
)
375376

376377
async def stop(self):

0 commit comments

Comments
 (0)