diff --git a/anaxi/checkpoint.py b/anaxi/checkpoint.py index d4131dc..3061bd7 100644 --- a/anaxi/checkpoint.py +++ b/anaxi/checkpoint.py @@ -3,6 +3,9 @@ import pathlib from typing import Union from anaxi.file_persistence import read_yaml, write_yaml +from anaxi.logging import get_anaxi_logger + +logger = get_anaxi_logger(__name__) class CheckpointManager: @@ -41,6 +44,9 @@ class CheckpointManager: ).isoformat() }, ) + logger.info( + f"New checkpoint at {self.highest_synced_timestamp.astimezone(tz=datetime.timezone.utc)}" + ) def set_new_goal(self, goal_timestamp: datetime.datetime) -> None: self.goal = goal_timestamp diff --git a/anaxi/sync.py b/anaxi/sync.py index 907b6c7..8f22235 100644 --- a/anaxi/sync.py +++ b/anaxi/sync.py @@ -75,9 +75,6 @@ class SyncJob: postgres_cursor, ) logger.info("Committed batch.") - logger.info( - f"Checkpoint is a now at: {self.checkpoint_manager.highest_synced_timestamp}" - ) docs_batch = []