Skip to content

Commit 6411d96

Browse files
authored
Merge pull request #168 from amoscatelli/master
waiting for table to be ready
2 parents cbdd1c6 + be409d9 commit 6411d96

File tree

4 files changed

+8
-1
lines changed

4 files changed

+8
-1
lines changed

dynamodb-driver/src/main/java/org/eclipse/jnosql/communication/dynamodb/DynamoDBBuilders.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
* Contributors:
1212
*
1313
* Otavio Santana
14+
* Alessandro Moscatelli
1415
*/
1516

1617
package org.eclipse.jnosql.communication.dynamodb;

dynamodb-driver/src/main/java/org/eclipse/jnosql/communication/dynamodb/DynamoDBUtils.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
* Contributors:
1212
*
1313
* Otavio Santana
14+
* Alessandro Moscatelli
1415
*/
1516
package org.eclipse.jnosql.communication.dynamodb;
1617

dynamodb-driver/src/main/java/org/eclipse/jnosql/communication/dynamodb/DynamoTableUtils.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
* Contributors:
1212
*
1313
* Otavio Santana
14+
* Alessandro Moscatelli
1415
*/
1516
package org.eclipse.jnosql.communication.dynamodb;
1617

@@ -134,12 +135,15 @@ private static void createTable(String tableName, DynamoDbClient client, Long re
134135

135136
Map<String, KeyType> keyDefinition = createKeyDefinition();
136137
Map<String, ScalarAttributeType> attributeDefinition = createAttributesType();
137-
138+
138139
client.createTable(CreateTableRequest.builder()
139140
.tableName(tableName)
140141
.provisionedThroughput(createProvisionedThroughput(readCapacityUnits, writeCapacityUnit))
141142
.keySchema(createKeyElementSchema(keyDefinition))
142143
.attributeDefinitions(createAttributeDefinition(attributeDefinition))
143144
.build());
145+
146+
client.waiter().waitUntilTableExists(t -> t.tableName(tableName));
147+
144148
}
145149
}

dynamodb-driver/src/main/java/org/eclipse/jnosql/communication/dynamodb/keyvalue/DynamoDBBucketManager.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -11,6 +11,7 @@
1111
* Contributors:
1212
*
1313
* Otavio Santana
14+
* Alessandro Moscatelli
1415
*/
1516
package org.eclipse.jnosql.communication.dynamodb.keyvalue;
1617

0 commit comments

Comments
 (0)