From a3da89916ac1f0181c64cca9c03c455852516f81 Mon Sep 17 00:00:00 2001 From: Mohammad Amin Date: Wed, 6 Nov 2024 16:10:11 +0330 Subject: [PATCH] feat: creating telegram summary date index on timestamp data! --- dags/hivemind_telegram_etl.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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)