diff --git a/blockchainetl_common/streaming/streamer.py b/blockchainetl_common/streaming/streamer.py index 09f53f1..b933eda 100644 --- a/blockchainetl_common/streaming/streamer.py +++ b/blockchainetl_common/streaming/streamer.py @@ -90,9 +90,11 @@ def _sync_cycle(self): target_block = self._calculate_target_block(current_block, self.last_synced_block) blocks_to_sync = max(target_block - self.last_synced_block, 0) + lagging_by = current_block - self.last_synced_block - logging.info('Current block {}, target block {}, last synced block {}, blocks to sync {}'.format( - current_block, target_block, self.last_synced_block, blocks_to_sync)) + logging.info( + f'Current block {current_block}, target block {target_block}, last synced block {self.last_synced_block}, ' + f'blocks to sync {blocks_to_sync} lagging by {lagging_by}') if blocks_to_sync != 0: self.blockchain_streamer_adapter.export_all(self.last_synced_block + 1, target_block) diff --git a/setup.py b/setup.py index 2558eee..7b70114 100644 --- a/setup.py +++ b/setup.py @@ -11,7 +11,7 @@ def read(fname): setup( name='blockchain-etl-common', - version='1.6.1', + version='1.6.2', author='Evgeny Medvedev', author_email='evge.medvedev@gmail.com', description='Common utils for Blockchain ETL',