diff --git a/silverback/persistence.py b/silverback/persistence.py index 1e34ffae..2d7cabde 100644 --- a/silverback/persistence.py +++ b/silverback/persistence.py @@ -186,9 +186,9 @@ async def set_instance_state( await state.set( # Unreported type error? Confiremd working { - SilverbackStateDoc.last_block_seen: last_block_seen, # type: ignore - SilverbackStateDoc.last_block_processed: last_block_processed, # type: ignore - SilverbackStateDoc.updated: now_utc, # type: ignore + SilverbackStateDoc.last_block_seen: last_block_seen, # type: ignore # noqa: E501 + SilverbackStateDoc.last_block_processed: last_block_processed, # type: ignore # noqa: E501 + SilverbackStateDoc.updated: now_utc, # type: ignore # noqa: E501 } ) else: diff --git a/silverback/runner.py b/silverback/runner.py index 8a0020fa..72bec454 100644 --- a/silverback/runner.py +++ b/silverback/runner.py @@ -59,7 +59,10 @@ async def _checkpoint( or last_block_processed > self.last_block_processed ): logger.debug( - f"Checkpoint block [seen={self.last_block_seen}, procssed={self.last_block_processed}]" + ( + f"Checkpoint block [seen={self.last_block_seen}, " + f"procssed={self.last_block_processed}]" + ) ) self.last_block_seen = max(last_block_seen, self.last_block_seen) self.last_block_processed = max(last_block_processed, self.last_block_processed)