Yasuke/moto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Firehose timestamps need a timezone or a 'Z' at the end (#4459)

Browse Source
This commit is contained in:
kbalk 2021-10-22 10:48:46 -04:00 committed by GitHub
parent 3d6ffcc74d
commit e2f7a1500d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
moto/firehose/models.py
View File

@ -16,7 +16,7 @@ Incomplete list of unfinished items:
- put_record(), put_record_batch() always set "Encrypted" to False. - put_record(), put_record_batch() always set "Encrypted" to False.
""" """
from base64 import b64decode, b64encode from base64 import b64decode, b64encode
from datetime import datetime from datetime import datetime, timezone
from gzip import GzipFile from gzip import GzipFile
import io import io
import json import json
@ -154,11 +154,11 @@ class DeliveryStream(
self.delivery_stream_status = "ACTIVE" self.delivery_stream_status = "ACTIVE"
self.delivery_stream_arn = f"arn:aws:firehose:{region}:{ACCOUNT_ID}:/delivery_stream/{delivery_stream_name}" self.delivery_stream_arn = f"arn:aws:firehose:{region}:{ACCOUNT_ID}:/delivery_stream/{delivery_stream_name}"
self.create_timestamp = datetime.utcnow().isoformat() self.create_timestamp = datetime.now(timezone.utc).isoformat()
self.version_id = "1" # Used to track updates of destination configs self.version_id = "1" # Used to track updates of destination configs
# I believe boto3 only adds this field after an update ... # I believe boto3 only adds this field after an update ...
self.last_update_timestamp = datetime.utcnow().isoformat() self.last_update_timestamp = datetime.now(timezone.utc).isoformat()
class FirehoseBackend(BaseBackend): class FirehoseBackend(BaseBackend):
@ -622,7 +622,7 @@ class FirehoseBackend(BaseBackend):
# Increment version number and update the timestamp. # Increment version number and update the timestamp.
delivery_stream.version_id = str(int(current_delivery_stream_version_id) + 1) delivery_stream.version_id = str(int(current_delivery_stream_version_id) + 1)
delivery_stream.last_update_timestamp = datetime.utcnow().isoformat() delivery_stream.last_update_timestamp = datetime.now(timezone.utc).isoformat()
# Unimplemented: processing of the "S3BackupMode" parameter. Per the # Unimplemented: processing of the "S3BackupMode" parameter. Per the
# documentation: "You can update a delivery stream to enable Amazon # documentation: "You can update a delivery stream to enable Amazon