diff --git a/src/demo_hic_et_nunc/handlers/on_rollback.py b/src/demo_hic_et_nunc/handlers/on_rollback.py index 42059fdc1..ce12d06f5 100644 --- a/src/demo_hic_et_nunc/handlers/on_rollback.py +++ b/src/demo_hic_et_nunc/handlers/on_rollback.py @@ -9,5 +9,7 @@ async def on_rollback( from_level: int, to_level: int, ) -> None: + if from_level - to_level == 1: + return _logger.warning('Rollback event received, reindexing') await reindex() diff --git a/src/demo_quipuswap/handlers/on_rollback.py b/src/demo_quipuswap/handlers/on_rollback.py index 42059fdc1..ce12d06f5 100644 --- a/src/demo_quipuswap/handlers/on_rollback.py +++ b/src/demo_quipuswap/handlers/on_rollback.py @@ -9,5 +9,7 @@ async def on_rollback( from_level: int, to_level: int, ) -> None: + if from_level - to_level == 1: + return _logger.warning('Rollback event received, reindexing') await reindex() diff --git a/src/demo_registrydao/handlers/on_rollback.py b/src/demo_registrydao/handlers/on_rollback.py index 42059fdc1..ce12d06f5 100644 --- a/src/demo_registrydao/handlers/on_rollback.py +++ b/src/demo_registrydao/handlers/on_rollback.py @@ -9,5 +9,7 @@ async def on_rollback( from_level: int, to_level: int, ) -> None: + if from_level - to_level == 1: + return _logger.warning('Rollback event received, reindexing') await reindex() diff --git a/src/demo_tzcolors/handlers/on_rollback.py b/src/demo_tzcolors/handlers/on_rollback.py index 42059fdc1..ce12d06f5 100644 --- a/src/demo_tzcolors/handlers/on_rollback.py +++ b/src/demo_tzcolors/handlers/on_rollback.py @@ -9,5 +9,7 @@ async def on_rollback( from_level: int, to_level: int, ) -> None: + if from_level - to_level == 1: + return _logger.warning('Rollback event received, reindexing') await reindex() diff --git a/src/dipdup/templates/on_rollback.py.j2 b/src/dipdup/templates/on_rollback.py.j2 index 42059fdc1..ce12d06f5 100644 --- a/src/dipdup/templates/on_rollback.py.j2 +++ b/src/dipdup/templates/on_rollback.py.j2 @@ -9,5 +9,7 @@ async def on_rollback( from_level: int, to_level: int, ) -> None: + if from_level - to_level == 1: + return _logger.warning('Rollback event received, reindexing') await reindex()