From 85489d9ea9761dbfd5c3f3c80ec92993514ed769 Mon Sep 17 00:00:00 2001 From: Sean Whalen Date: Sun, 18 Nov 2018 16:52:17 -0500 Subject: [PATCH] PEP8 fixes --- parsedmarc/cli.py | 6 ++++-- parsedmarc/elastic.py | 3 ++- 2 files changed, 6 insertions(+), 3 deletions(-) diff --git a/parsedmarc/cli.py b/parsedmarc/cli.py index f65b08b..dfb1e1b 100644 --- a/parsedmarc/cli.py +++ b/parsedmarc/cli.py @@ -37,7 +37,8 @@ def _main(): try: if args.elasticsearch_host: elastic.save_aggregate_report_to_elasticsearch( - report, index_suffix=args.elasticsearch_index_suffix) + report, + index_suffix=args.elasticsearch_index_suffix) except elastic.AlreadySaved as warning: logger.warning(warning.__str__()) except elastic.ElasticsearchError as error_: @@ -63,7 +64,8 @@ def _main(): try: if args.elasticsearch_host: elastic.save_forensic_report_to_elasticsearch( - report, index_suffix=args.elasticsearch_index_suffix) + report, + index_suffix=args.elasticsearch_index_suffix) except elastic.AlreadySaved as warning: logger.warning(warning.__str__()) except elastic.ElasticsearchError as error_: diff --git a/parsedmarc/elastic.py b/parsedmarc/elastic.py index 9a5be64..87d8f79 100644 --- a/parsedmarc/elastic.py +++ b/parsedmarc/elastic.py @@ -244,7 +244,8 @@ def migrate_indexes(aggregate_indexes=None, forensic_indexes=None): } Index(new_index_name).create() Index(new_index_name).put_mapping(doc_type=doc, body=body) - reindex(connections.get_connection(), aggregate_index_name, new_index_name) + reindex(connections.get_connection(), aggregate_index_name, + new_index_name) Index(aggregate_index_name).delete() for forensic_index in forensic_indexes: