diff --git a/dags/hivemind_telegram_etl.py b/dags/hivemind_telegram_etl.py index 8d0d7101..d40e2eda 100644 --- 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)