Clear queue on reconnect (#98)

dipdup-io · Jul 19, 2021 · 2566cc1 · 2566cc1
1 parent d7a0888
commit 2566cc1
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/dipdup/index.py b/src/dipdup/index.py
@@ -29,6 +29,8 @@
 
 
 class Index:
+    _queue: Deque
+
     def __init__(self, ctx: DipDupContext, config: IndexConfigTemplateT, datasource: TzktDatasource) -> None:
         self._ctx = ctx
         self._config = config
@@ -58,6 +60,7 @@ async def process(self) -> None:
             await self._synchronize(last_level)
         elif self._datasource.sync_level > state.level:
             self._logger.info('Index is behind datasource, sync to datasource level')
+            self._queue.clear()
             last_level = self._datasource.sync_level
             await self._synchronize(last_level)
         else: