From eea57a5719f6b5fe27d915469797e5d4be2415a0 Mon Sep 17 00:00:00 2001 From: Sean Whalen Date: Sun, 25 Mar 2018 23:12:07 -0400 Subject: [PATCH] PEP8 fixes --- parsedmarc/elastic.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/parsedmarc/elastic.py b/parsedmarc/elastic.py index a9f6355..2b6e0af 100644 --- a/parsedmarc/elastic.py +++ b/parsedmarc/elastic.py @@ -183,7 +183,7 @@ def create_indexes(): def save_aggregate_report_to_elasticsearch(aggregate_report): """ Saves a parsed DMARC aggregate report to ElasticSearch - + Args: aggregate_report (OrderedDict): A parsed forensic report @@ -290,8 +290,10 @@ def save_forensic_report_to_elasticsearch(forensic_report): to_query = {"match": {"sample.headers.to": headers["to"]}} from_query = {"match": {"sample.headers.from": headers["from"]}} subject_query = {"match": {"sample.headers.subject": headers["subject"]}} - arrival_date_query = {"match": {"sample.headers.arrival_date": forensic_report["arrival_date_utc"]}} - search.query = Q(to_query) & Q(from_query) & Q(subject_query) & Q(arrival_date_query) + arrival_date_query = {"match": {"sample.headers.arrival_date": arrival_date + }} + q = Q(to_query) & Q(from_query) & Q(subject_query) & Q(arrival_date_query) + search.query = q existing = search.execute() if len(existing) > 0: