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