Skip to content

Commit

Permalink
don't crash on get_sync_level
Browse files Browse the repository at this point in the history
  • Loading branch information
droserasprout committed Dec 26, 2023
1 parent e710729 commit d5dcad1
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion src/dipdup/dipdup.py
Original file line number Diff line number Diff line change
Expand Up @@ -223,14 +223,19 @@ async def _update_metrics(self) -> None:

levels_indexed, levels_total, levels_interval = 0, 0, 0
for index in self._indexes.values():
try:
sync_level = index.get_sync_level()
except FrameworkException:
return

initial_level = self._initial_levels[index.name]
if not initial_level:
self._initial_levels[index.name] |= index.state.level
continue

levels_interval += index.state.level - self._previous_levels[index.name]
levels_indexed += index.state.level - initial_level
levels_total += index.get_sync_level() - initial_level
levels_total += sync_level - initial_level

self._previous_levels[index.name] = index.state.level

Expand Down

0 comments on commit d5dcad1

Please sign in to comment.