feat: creating telegram summary date index on timestamp data!

TogetherCrew · Nov 6, 2024 · a3da899 · a3da899
1 parent 22e298b
commit a3da899
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dags/hivemind_telegram_etl.py b/dags/hivemind_telegram_etl.py
@@ -105,7 +105,7 @@ def process_data(messages):
                 transformer = TransformSummary()
                 collection_name = "telegram_summary"
                 date_field = "date"
-                date_schema = models.PayloadSchemaType.DATETIME
+                date_schema = models.PayloadSchemaType.FLOAT
 
                 def process_data(messages):
                     summaries = summarizer.summarize_daily(messages=messages)