From c6f8c82214bd92a7812f7e1ab1edd8fba1034988 Mon Sep 17 00:00:00 2001 From: Hussein Awala Date: Thu, 31 Aug 2023 01:23:54 +0200 Subject: [PATCH] Replace dict.items by dict.values when key is not used in Airflow core --- airflow/models/dag.py | 2 +- airflow/utils/log/trigger_handler.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/models/dag.py b/airflow/models/dag.py index 5979c51c518fa..cd3f47da88430 100644 --- a/airflow/models/dag.py +++ b/airflow/models/dag.py @@ -3275,7 +3275,7 @@ def validate_schedule_and_params(self): if not self.timetable.can_be_scheduled: return - for k, v in self.params.items(): + for v in self.params.values(): # As type can be an array, we would check if `null` is an allowed type or not if not v.has_value and ("type" not in v.schema or "null" not in v.schema["type"]): raise AirflowException( diff --git a/airflow/utils/log/trigger_handler.py b/airflow/utils/log/trigger_handler.py index 42afcd8afeb5a..aa9a43ec87ad5 100644 --- a/airflow/utils/log/trigger_handler.py +++ b/airflow/utils/log/trigger_handler.py @@ -113,7 +113,7 @@ def close_one(self, trigger_id): del self.handlers[trigger_id] def flush(self): - for _, h in self.handlers.items(): + for h in self.handlers.values(): h.flush() def close(self):