mirror of
https://github.com/domainaware/parsedmarc.git
synced 2026-05-15 00:15:26 +00:00
PEP8 fixes
This commit is contained in:
+4
-2
@@ -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_:
|
||||
|
||||
@@ -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:
|
||||
|
||||
Reference in New Issue
Block a user