store raw aggregate interval as header

dnstapir · Nov 15, 2023 · 85e887f · 85e887f
1 parent 351c3a7
commit 85e887f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/aggrec/aggregates.py b/aggrec/aggregates.py
@@ -30,6 +30,7 @@
     "Content-Encoding",
     "Signature",
     "Signature-Input",
+    "Aggregate-Interval",
 ]
 
 ALLOWED_AGGREGATE_TYPES = ["histogram", "vector"]
@@ -146,7 +147,8 @@ def get_new_aggregate_event_message(
                 ).strftime("%Y-%m-%dT%H:%M:%SZ"),
                 "interval_duration": metadata.aggregate_interval_duration,
             }
-            if metadata.aggregate_interval
+            if metadata.aggregate_interval_start
+            and metadata.aggregate_interval_duration
             else {}
         ),
     }
@@ -212,7 +214,6 @@ async def create_aggregate(
     metadata = AggregateMetadata(
         id=aggregate_id,
         aggregate_type=aggregate_type,
-        aggregate_interval=aggregate_interval,
         aggregate_interval_start=aggregate_interval_start,
         aggregate_interval_duration=aggregate_interval_duration,
         creator=creator,

diff --git a/aggrec/db_models.py b/aggrec/db_models.py
@@ -30,6 +30,5 @@ class AggregateMetadata(Document):
     s3_bucket = StringField()
     s3_object_key = StringField()
 
-    aggregate_interval = StringField()
     aggregate_interval_start = DateTimeField()
     aggregate_interval_duration = IntField()