From c8134fda4a0cd2a6079fdf95f6c05b014570b575 Mon Sep 17 00:00:00 2001 From: Erik Olson Date: Tue, 7 Jan 2020 21:52:51 -0500 Subject: [PATCH] purg_ttl.py pep8 --- tools/spanner/purge_ttl.py | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/tools/spanner/purge_ttl.py b/tools/spanner/purge_ttl.py index 13f4517f..7ac9b694 100644 --- a/tools/spanner/purge_ttl.py +++ b/tools/spanner/purge_ttl.py @@ -14,8 +14,10 @@ from urllib import parse from google.cloud import spanner # set up logger -logging.basicConfig(format='{"datetime": "%(asctime)s", "message": "%(message)s"}', - stream=sys.stdout,level=logging.INFO) +logging.basicConfig( + format='{"datetime": "%(asctime)s", "message": "%(message)s"}', + stream=sys.stdout, + level=logging.INFO) # Change these to match your install. client = spanner.Client() @@ -53,7 +55,8 @@ def spanner_read_data(request=None): query = 'DELETE FROM batches WHERE expiry < CURRENT_TIMESTAMP()' result = database.execute_partitioned_dml(query) batches_end = datetime.now() - logging.info("batches: removed {} rows, batches_duration: {}".format(result, batches_end - batches_start)) + logging.info("batches: removed {} rows, batches_duration: {}".format( + result, batches_end - batches_start)) # Delete BSOs with statsd.timer("syncstorage.purge_ttl.bso_duration"): @@ -61,7 +64,8 @@ def spanner_read_data(request=None): query = 'DELETE FROM bsos WHERE expiry < CURRENT_TIMESTAMP()' result = database.execute_partitioned_dml(query) bso_end = datetime.now() - logging.info("bso: removed {} rows, bso_duration: {}".format(result, bso_end - bso_start)) + logging.info("bso: removed {} rows, bso_duration: {}".format( + result, bso_end - bso_start)) if __name__ == "__main__": @@ -73,4 +77,5 @@ if __name__ == "__main__": end_time = datetime.now() duration = end_time - start_time - logging.info('Completed purge_ttl.py, total_duration: {}'.format(duration)) + logging.info( + 'Completed purge_ttl.py, total_duration: {}'.format(duration))