diff --git a/dags/discourse_analyzer_etl.py b/dags/discourse_analyzer_etl.py index d209c841..1e59ec19 100644 --- a/dags/discourse_analyzer_etl.py +++ b/dags/discourse_analyzer_etl.py @@ -182,11 +182,10 @@ def analyze_discourse(platform_processed: dict[str, str | bool]) -> None: platform_data = fetcher.fetch_analyzer_parameters(platform_id) - metadata = platform_data["metadata"] - period = metadata["period"] - action = metadata["action"] - window = metadata["window"] - resources = metadata["resources"] + period = platform_data["period"] + action = platform_data["action"] + window = platform_data["window"] + resources = platform_data["resources"] analyzer = Analyzer()