From 112514d540f696507469e878b46db76da962661f Mon Sep 17 00:00:00 2001 From: Charles Knipe Date: Fri, 13 Sep 2019 16:04:31 -0400 Subject: [PATCH 1/3] Skip throughput update on restore --- dynamodump.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/dynamodump.py b/dynamodump.py index b873704d..03bdb6ba 100755 --- a/dynamodump.py +++ b/dynamodump.py @@ -689,14 +689,14 @@ def do_restore(dynamo, sleep_interval, source_table, destination_table, write_ca # wait for table creation completion wait_for_active_table(dynamo, destination_table, "created") - else: + elif not args.skipThroughputUpdate: # update provisioned capacity if int(write_capacity) > original_write_capacity: update_provisioned_throughput(dynamo, - destination_table, - original_read_capacity, - write_capacity, - False) + destination_table, + original_read_capacity, + write_capacity, + False) if not args.schemaOnly: # read data files From aba3bdb5662a091bb66752733d11d746b88f1227 Mon Sep 17 00:00:00 2001 From: Charles Knipe Date: Fri, 13 Sep 2019 16:32:06 -0400 Subject: [PATCH 2/3] Fix spacing issue --- dynamodump.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/dynamodump.py b/dynamodump.py index 03bdb6ba..59b9e519 100755 --- a/dynamodump.py +++ b/dynamodump.py @@ -693,11 +693,10 @@ def do_restore(dynamo, sleep_interval, source_table, destination_table, write_ca # update provisioned capacity if int(write_capacity) > original_write_capacity: update_provisioned_throughput(dynamo, - destination_table, - original_read_capacity, - write_capacity, - False) - + destination_table, + original_read_capacity, + write_capacity, + False) if not args.schemaOnly: # read data files logging.info("Restoring data for " + destination_table + " table..") From 75cac7d8181a6c548dddd848f4d68fd5fca885b9 Mon Sep 17 00:00:00 2001 From: Charles Knipe Date: Fri, 13 Sep 2019 16:32:59 -0400 Subject: [PATCH 3/3] mend --- dynamodump.py | 1 + 1 file changed, 1 insertion(+) diff --git a/dynamodump.py b/dynamodump.py index 59b9e519..d92e3225 100755 --- a/dynamodump.py +++ b/dynamodump.py @@ -697,6 +697,7 @@ def do_restore(dynamo, sleep_interval, source_table, destination_table, write_ca original_read_capacity, write_capacity, False) + if not args.schemaOnly: # read data files logging.info("Restoring data for " + destination_table + " table..")