From e966a965d079129d224fe64c6b2bd92199c4accb Mon Sep 17 00:00:00 2001 From: Marat Sharafutdinov Date: Thu, 28 Dec 2023 22:15:03 +0300 Subject: [PATCH] Add UTC timezone for decoded naive timestamp --- aio_pika/message.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/aio_pika/message.py b/aio_pika/message.py index 58f441a8..df8c2bd2 100644 --- a/aio_pika/message.py +++ b/aio_pika/message.py @@ -106,6 +106,8 @@ def decode_timestamp(value: Any) -> Optional[datetime]: @decode_timestamp.register(datetime) def decode_timestamp_datetime(value: datetime) -> datetime: + if value.tzinfo is None or value.tzinfo.utcoffset(value) is None: + value = value.replace(tzinfo=timezone.utc) return value