diff --git a/dags/hivemind_telegram_etl.py b/dags/hivemind_telegram_etl.py index d40e2eda..81d01bea 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.FLOAT + date_schema = models.PayloadSchemaType.TEXT def process_data(messages): summaries = summarizer.summarize_daily(messages=messages)