From f18bc98a965e4fc07269f60283d0a05ae8ea8202 Mon Sep 17 00:00:00 2001 From: Sean Whalen Date: Thu, 11 Oct 2018 14:01:40 -0400 Subject: [PATCH] Sigh --- parsedmarc/elastic.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/parsedmarc/elastic.py b/parsedmarc/elastic.py index c14f012..8e1fe06 100644 --- a/parsedmarc/elastic.py +++ b/parsedmarc/elastic.py @@ -8,6 +8,8 @@ from elasticsearch_dsl.search import Q from elasticsearch_dsl import connections, Object, Document, Index, Nested, \ InnerDoc, Integer, Text, Boolean, DateRange, Ip, Date +from parsedmarc.utils import human_timestamp_to_datetime + logger = logging.getLogger("parsedmarc") @@ -211,8 +213,8 @@ def save_aggregate_report_to_elasticsearch(aggregate_report, org_name = metadata["org_name"] report_id = metadata["report_id"] domain = aggregate_report["policy_published"]["domain"] - begin_date = parsedmarc.human_timestamp_to_datetime(metadata["begin_date"]) - end_date = parsedmarc.human_timestamp_to_datetime(metadata["end_date"]) + begin_date = human_timestamp_to_datetime(metadata["begin_date"]) + end_date = human_timestamp_to_datetime(metadata["end_date"]) begin_date_human = begin_date.strftime("%Y-%m-%d %H:%M:%S") end_date_human = end_date.strftime("%Y-%m-%d %H:%M:%S") aggregate_report["begin_date"] = begin_date