From 29c93a3b4c3a9d5d92872f33a7c310ec3078c44b Mon Sep 17 00:00:00 2001 From: Mohammad Amin Date: Mon, 7 Oct 2024 09:37:43 +0330 Subject: [PATCH] fix: variable name wrong name! --- dags/telegram_analyzer_etl.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/dags/telegram_analyzer_etl.py b/dags/telegram_analyzer_etl.py index 8ef40470..13e54be0 100644 --- a/dags/telegram_analyzer_etl.py +++ b/dags/telegram_analyzer_etl.py @@ -215,8 +215,8 @@ def analyze_telegram(platform_processed: dict[str, str | bool]) -> None: raw_data_etl = telegram_etl_raw_data.expand(platform_info=platform_modules) raw_members_etl = telegram_etl_raw_members.expand(platform_info=platform_modules) - analyze_discourse_task = analyze_telegram.expand( + analyze_telegram_task = analyze_telegram.expand( platform_processed=platform_modules ) - [raw_data_etl, raw_members_etl] >> analyze_discourse_task + [raw_data_etl, raw_members_etl] >> analyze_telegram_task