static checks

ferruzzi · ferruzzi · commit 94ae01233d8c · 2026-02-28T21:45:52.000-08:00
diff --git a/airflow-core/src/airflow/executors/base_executor.py b/airflow-core/src/airflow/executors/base_executor.py
@@ -247,9 +247,7 @@ def queue_workload(self, workload: ExecutorWorkload, session: Session) -> None:
                 f"Workload must be one of: ExecuteTask, ExecuteCallback."
             )
 
-    def _get_workloads_to_schedule(
-        self, open_slots: int
-    ) -> list[tuple[WorkloadKey, ExecutorWorkload]]:
+    def _get_workloads_to_schedule(self, open_slots: int) -> list[tuple[WorkloadKey, ExecutorWorkload]]:
         """
         Select and return the next batch of workloads to schedule, respecting priority policy.
 

Original file line number	Diff line number	Diff line change
`@@ -247,9 +247,7 @@ def queue_workload(self, workload: ExecutorWorkload, session: Session) -> None:`
`247`	`247`	`f"Workload must be one of: ExecuteTask, ExecuteCallback."`
`248`	`248`	`)`
`249`	`249`
`250`		`- def _get_workloads_to_schedule(`
`251`		`- self, open_slots: int`
`252`		`- ) -> list[tuple[WorkloadKey, ExecutorWorkload]]:`
	`250`	`+ def _get_workloads_to_schedule(self, open_slots: int) -> list[tuple[WorkloadKey, ExecutorWorkload]]:`
`253`	`251`	`"""`
`254`	`252`	`Select and return the next batch of workloads to schedule, respecting priority policy.`
`255`	`253`