Fix checkpoint for timestamps

SEKOIA-IO · Nov 29, 2024 · 707f3fc · 707f3fc
1 parent ad04fd8
commit 707f3fc
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sekoia_automation/checkpoint.py b/sekoia_automation/checkpoint.py
@@ -182,7 +182,7 @@ def from_datetime(self, dt) -> int:
 
     def to_datetime(self, rp: float | int) -> datetime:
         # timestamp -> inner representation
-        return datetime.fromtimestamp(rp / self.multiplier).replace(tzinfo=timezone.utc)
+        return datetime.fromtimestamp(rp / self.multiplier).astimezone(timezone.utc)
 
 
 class CheckpointCursor(Checkpoint):