Fix json encoding issue.
This commit is contained in:
parent
a6f14eee3f
commit
0a7d299da3
@ -586,7 +586,7 @@ class StreamRecord(BaseModel):
|
|||||||
self.record["dynamodb"]["OldImage"] = old_a
|
self.record["dynamodb"]["OldImage"] = old_a
|
||||||
|
|
||||||
# This is a substantial overestimate but it's the easiest to do now
|
# This is a substantial overestimate but it's the easiest to do now
|
||||||
self.record["dynamodb"]["SizeBytes"] = len(json.dumps(self.record["dynamodb"]))
|
self.record["dynamodb"]["SizeBytes"] = len(dynamo_json_dump(self.record["dynamodb"]))
|
||||||
|
|
||||||
def to_json(self):
|
def to_json(self):
|
||||||
return self.record
|
return self.record
|
||||||
|
Loading…
x
Reference in New Issue
Block a user