This commit is contained in:
Bert Blommers 2020-02-18 12:34:24 +00:00
parent 9971bcdfcd
commit 5863d9fab9

View File

@ -1256,11 +1256,13 @@ def test_invoke_function_from_dynamodb_update():
assert response["EventSourceArn"] == table["TableDescription"]["LatestStreamArn"] assert response["EventSourceArn"] == table["TableDescription"]["LatestStreamArn"]
assert response["State"] == "Enabled" assert response["State"] == "Enabled"
dynamodb.update_item(TableName=table_name, dynamodb.update_item(
Key={'id': {'S': 'item 1'}}, TableName=table_name,
Key={"id": {"S": "item 1"}},
UpdateExpression="set #attr = :val", UpdateExpression="set #attr = :val",
ExpressionAttributeNames={'#attr': 'new_attr'}, ExpressionAttributeNames={"#attr": "new_attr"},
ExpressionAttributeValues={':val': {'S': 'new_val'}}) ExpressionAttributeValues={":val": {"S": "new_val"}},
)
start = time.time() start = time.time()
while (time.time() - start) < 30: while (time.time() - start) < 30:
result = logs_conn.describe_log_streams(logGroupName="/aws/lambda/testFunction") result = logs_conn.describe_log_streams(logGroupName="/aws/lambda/testFunction")