refactor: remove unused SilverbackApp.checkpoint() method

silverback/application.py

@@ -73,10 +73,6 @@ def __init__(self, settings: Optional[Settings] = None):
             f"{signer_str}{start_block_str}{new_block_timeout_str}"
         )
 
-    def checkpoint(self, last_block_seen: int, last_block_processed: int):
-        self.broker.state.last_block_seen = last_block_seen
-        self.broker.state.last_block_processed = last_block_processed
-
     def on_startup(self) -> Callable:
         """
         Code to execute on one worker upon startup / restart after an error.

silverback/runner.py

@@ -67,8 +67,6 @@ async def _checkpoint(
             self.last_block_seen = max(last_block_seen, self.last_block_seen)
             self.last_block_processed = max(last_block_processed, self.last_block_processed)
 
-            self.app.checkpoint(self.last_block_seen, self.last_block_processed)
-
             if self.persistence:
                 await self.persistence.set_instance_state(
                     self.ident, self.last_block_seen, self.last_block_processed
@@ -109,14 +107,6 @@ async def run(self):
                 self.last_block_seen = boot_state.last_block_seen
                 self.last_block_processed = boot_state.last_block_processed
 
-            # NOTE: This will update TaskIQ state before app startup.
-            # TODO: I have no idea if this will work with a distributed runner/worker
-            # setup.  That may require our own injected startup task, but it's unclear if
-            # we can do that before Taskiq's startup handlers.  We might be able to force
-            # SilverbackApplication to decorate an internal func to handle it.  Need to
-            # figure that out.
-            self.app.checkpoint(self.last_block_seen, self.last_block_processed)
-
         await self.app.broker.startup()
 
         # Execute Silverback startup task before we init the rest