skip part of the test in server mode.
This commit is contained in:
parent
299e7851d6
commit
7d4c15d53e
@ -394,9 +394,12 @@ def test_put_item_with_streams():
|
|||||||
"Data": {"M": {"Key1": {"S": "Value1"}, "Key2": {"S": "Value2"}}},
|
"Data": {"M": {"Key1": {"S": "Value1"}, "Key2": {"S": "Value2"}}},
|
||||||
}
|
}
|
||||||
)
|
)
|
||||||
stream_shard = dynamodb_backends2["us-west-2"].get_table(name).stream_shard
|
table = dynamodb_backends2["us-west-2"].get_table(name)
|
||||||
len(stream_shard.items).should.be.equal(1)
|
if not table:
|
||||||
stream_record = stream_shard.items[0].record
|
# There is no way to access stream data over the API, so this part can't run in server-tests mode.
|
||||||
|
return
|
||||||
|
len(table.stream_shard.items).should.be.equal(1)
|
||||||
|
stream_record = table.stream_shard.items[0].record
|
||||||
stream_record["eventName"].should.be.equal("INSERT")
|
stream_record["eventName"].should.be.equal("INSERT")
|
||||||
stream_record["dynamodb"]["SizeBytes"].should.be.equal(447)
|
stream_record["dynamodb"]["SizeBytes"].should.be.equal(447)
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user