Remove unused loop variable from airflow package

airflow/dag_processing/manager.py

@@ -1177,7 +1177,7 @@ def prepare_file_path_queue(self):
         ]
 
         if self.log.isEnabledFor(logging.DEBUG):
-            for file_path, processor in self._processors.items():
+            for processor in self._processors.values():
                 self.log.debug(
                     "File path %s is still being processed (started: %s)",
                     processor.file_path,

airflow/jobs/scheduler_job_runner.py

@@ -110,7 +110,7 @@ class ConcurrencyMap:
     @classmethod
     def from_concurrency_map(cls, mapping: dict[tuple[str, str, str], int]) -> ConcurrencyMap:
         instance = cls(Counter(), Counter(), Counter(mapping))
-        for (d, r, t), c in mapping.items():
+        for (d, _, t), c in mapping.items():
             instance.dag_active_tasks_map[d] += c
             instance.task_concurrency_map[(d, t)] += c
         return instance

airflow/providers/google/cloud/hooks/bigquery.py

@@ -3185,7 +3185,7 @@ def _validate_src_fmt_configs(
         if k not in src_fmt_configs and k in valid_configs:
             src_fmt_configs[k] = v
 
-    for k, v in src_fmt_configs.items():
+    for k in src_fmt_configs:
         if k not in valid_configs:
             raise ValueError(f"{k} is not a valid src_fmt_configs for type {source_format}.")
 

airflow/providers/google/cloud/transfers/gcs_to_bigquery.py

@@ -714,7 +714,7 @@ def _validate_src_fmt_configs(
             if k not in src_fmt_configs and k in valid_configs:
                 src_fmt_configs[k] = v
 
-        for k, v in src_fmt_configs.items():
+        for k in src_fmt_configs:
             if k not in valid_configs:
                 raise ValueError(f"{k} is not a valid src_fmt_configs for type {source_format}.")
 

airflow/providers/weaviate/hooks/weaviate.py

@@ -459,7 +459,7 @@ def _process_batch_errors(
         client.batch.configure(**batch_config_params)
         with client.batch as batch:
             # Batch import all data
-            for index, data_obj in enumerate(converted_data):
+            for data_obj in converted_data:
                 for attempt in Retrying(
                     stop=stop_after_attempt(retry_attempts_per_object),
                     retry=(

airflow/www/utils.py

@@ -790,7 +790,7 @@ class AirflowFilterConverter(fab_sqlafilters.SQLAFilterConverter):
     def __init__(self, datamodel):
         super().__init__(datamodel)
 
-        for method, filters in self.conversion_table:
+        for _, filters in self.conversion_table:
             if FilterIsNull not in filters:
                 filters.append(FilterIsNull)
             if FilterIsNotNull not in filters:

airflow/www/views.py

@@ -2147,7 +2147,7 @@ def trigger(self, dag_id: str, session: Session = NEW_SESSION):
             flash(f"{ve}", "error")
             form = DateTimeForm(data={"execution_date": execution_date})
             # Take over "bad" submitted fields for new form display
-            for k, v in form_fields.items():
+            for k in form_fields:
                 if k in run_conf:
                     form_fields[k]["value"] = run_conf[k]
             return self.render_template(
@@ -4597,7 +4597,7 @@ def process_form(self, form, is_created):
                 )
                 del form.extra
         del extra_json
-        for key, field_name, is_sensitive in self._iter_extra_field_names_and_sensitivity():
+        for key, field_name, _ in self._iter_extra_field_names_and_sensitivity():
             if key in form.data and key.startswith("extra__"):
                 conn_type_from_extra_field = key.split("__")[1]
                 if conn_type_from_extra_field == conn_type: