diff --git a/dags/telegram_analyzer_etl.py b/dags/telegram_analyzer_etl.py index 13e54be0..ddbb311a 100644 --- a/dags/telegram_analyzer_etl.py +++ b/dags/telegram_analyzer_etl.py @@ -215,8 +215,6 @@ 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_telegram_task = analyze_telegram.expand( - platform_processed=platform_modules - ) + analyze_telegram_task = analyze_telegram.expand(platform_processed=platform_modules) [raw_data_etl, raw_members_etl] >> analyze_telegram_task