fixed static check

Author: SakshamSinghal20

airflow-core/src/airflow/jobs/scheduler_job_runner.py

@@ -1239,9 +1239,7 @@ def process_executor_events(
                     # Safely extract bundle info: prefer dag_version when available,
                     # fall back to dag_model/dag_run for legacy tasks migrated from
                     # Airflow 2 where dag_version may be None (AIP-66).
-                    _bundle_name = (
-                        ti.dag_version.bundle_name if ti.dag_version else ti.dag_model.bundle_name
-                    )
+                    _bundle_name = ti.dag_version.bundle_name if ti.dag_version else ti.dag_model.bundle_name
                     _bundle_version = (
                         ti.dag_version.bundle_version if ti.dag_version else ti.dag_run.bundle_version
                     )
@@ -2983,9 +2981,7 @@ def _purge_task_instances_without_heartbeats(
             )
             # Safely extract bundle info with fallback for legacy tasks
             # (dag_version may be None after Airflow 2 → 3 migration).
-            _hb_bundle_name = (
-                ti.dag_version.bundle_name if ti.dag_version else ti.dag_model.bundle_name
-            )
+            _hb_bundle_name = ti.dag_version.bundle_name if ti.dag_version else ti.dag_model.bundle_name
             _hb_bundle_version = (
                 ti.dag_version.bundle_version if ti.dag_version else ti.dag_run.bundle_version
             )

airflow-core/tests/unit/jobs/test_scheduler_job.py

@@ -2836,7 +2836,6 @@ def test_purge_without_heartbeat_skips_when_missing_dag_version(self, dag_maker,
         assert any("Backfilled dag_version_id" in rec.message for rec in caplog.records)
         mock_executor.send_callback.assert_called_once()
 
-
     @staticmethod
     def mock_failure_callback(context):
         pass
@@ -9053,7 +9052,7 @@ class TestSchedulerCallbackBundleInfoDagVersionNullable:
     # ── With dag_version present ──────────────────────────────────────────
 
     @pytest.mark.parametrize(
-        "dv_bundle_name, dv_bundle_version",
+        ("dv_bundle_name", "dv_bundle_version"),
         [
             pytest.param("my-bundle", "v2.0", id="normal"),
             pytest.param("dags-folder", None, id="version_none"),
@@ -9071,7 +9070,7 @@ def test_bundle_info_from_dag_version_when_present(self, dv_bundle_name, dv_bund
     # ── With dag_version None (legacy Airflow 2 task) ─────────────────────
 
     @pytest.mark.parametrize(
-        "model_bundle_name, run_bundle_version",
+        ("model_bundle_name", "run_bundle_version"),
         [
             pytest.param("fallback-bundle", "v1.0-fallback", id="normal_fallback"),
             pytest.param("dags-folder", None, id="version_none_fallback"),
@@ -9103,9 +9102,7 @@ def test_no_attribute_error_regardless_of_dag_version(self, dag_version_present)
         The old code crashed with AttributeError when ti.dag_version was None.
         The new fallback must never raise regardless of dag_version state.
         """
-        ti = _make_ti_with_dag_version(
-            dag_version=_make_dag_version() if dag_version_present else None
-        )
+        ti = _make_ti_with_dag_version(dag_version=_make_dag_version() if dag_version_present else None)
 
         name = _extract_bundle_name(ti)
         version = _extract_bundle_version(ti)

ruff_lint.txt

@@ -0,0 +1,24 @@
+PT006 Wrong type passed to first argument of `pytest.mark.parametrize`; expected `tuple`
+    --> airflow-core\tests\unit\jobs\test_scheduler_job.py:9055:9
+     |
+9054 |     @pytest.mark.parametrize(
+9055 |         "dv_bundle_name, dv_bundle_version",
+     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
+9056 |         [
+9057 |             pytest.param("my-bundle", "v2.0", id="normal"),
+     |
+help: Use a `tuple` for the first argument
+
+PT006 Wrong type passed to first argument of `pytest.mark.parametrize`; expected `tuple`
+    --> airflow-core\tests\unit\jobs\test_scheduler_job.py:9073:9
+     |
+9072 |     @pytest.mark.parametrize(
+9073 |         "model_bundle_name, run_bundle_version",
+     |         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
+9074 |         [
+9075 |             pytest.param("fallback-bundle", "v1.0-fallback", id="normal_fallback"),
+     |
+help: Use a `tuple` for the first argument
+
+Found 2 errors.
+No fixes available (2 hidden fixes can be enabled with the `--unsafe-fixes` option).

ruff_output.txt

@@ -0,0 +1,23 @@
+--- airflow-core\tests\unit\jobs\test_scheduler_job.py
+1 file would be reformatted
++++ airflow-core\tests\unit\jobs\test_scheduler_job.py
+@@ -2836,7 +2836,6 @@
+         assert any("Backfilled dag_version_id" in rec.message for rec in caplog.records)
+         mock_executor.send_callback.assert_called_once()
+ 
+-
+     @staticmethod
+     def mock_failure_callback(context):
+         pass
+@@ -9103,9 +9102,7 @@
+         The old code crashed with AttributeError when ti.dag_version was None.
+         The new fallback must never raise regardless of dag_version state.
+         """
+-        ti = _make_ti_with_dag_version(
+-            dag_version=_make_dag_version() if dag_version_present else None
+-        )
++        ti = _make_ti_with_dag_version(dag_version=_make_dag_version() if dag_version_present else None)
+ 
+         name = _extract_bundle_name(ti)
+         version = _extract_bundle_version(ti)
+

ruff_output2.txt

@@ -0,0 +1,26 @@
+--- airflow-core\src\airflow\jobs\scheduler_job_runner.py
+1 file would be reformatted
++++ airflow-core\src\airflow\jobs\scheduler_job_runner.py
+@@ -1239,9 +1239,7 @@
+                     # Safely extract bundle info: prefer dag_version when available,
+                     # fall back to dag_model/dag_run for legacy tasks migrated from
+                     # Airflow 2 where dag_version may be None (AIP-66).
+-                    _bundle_name = (
+-                        ti.dag_version.bundle_name if ti.dag_version else ti.dag_model.bundle_name
+-                    )
++                    _bundle_name = ti.dag_version.bundle_name if ti.dag_version else ti.dag_model.bundle_name
+                     _bundle_version = (
+                         ti.dag_version.bundle_version if ti.dag_version else ti.dag_run.bundle_version
+                     )
+@@ -2983,9 +2981,7 @@
+             )
+             # Safely extract bundle info with fallback for legacy tasks
+             # (dag_version may be None after Airflow 2 → 3 migration).
+-            _hb_bundle_name = (
+-                ti.dag_version.bundle_name if ti.dag_version else ti.dag_model.bundle_name
+-            )
++            _hb_bundle_name = ti.dag_version.bundle_name if ti.dag_version else ti.dag_model.bundle_name
+             _hb_bundle_version = (
+                 ti.dag_version.bundle_version if ti.dag_version else ti.dag_run.bundle_version
+             )
+