static checks fixes

apache · Jul 11, 2023 · 33b4cd1 · 33b4cd1
1 parent fd55406
commit 33b4cd1
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/airflow/executors/kubernetes_executor.py b/airflow/executors/kubernetes_executor.py
@@ -98,7 +98,7 @@ def _list_pods(self, query_kwargs):
     def _make_safe_label_value(self, input_value: str | datetime) -> str:
         """
         Normalize a provided label to be of valid length and characters.
-        See airflow.kubernetes.pod_generator.make_safe_label_value for more details
+        See airflow.kubernetes.pod_generator.make_safe_label_value for more details.
         """
         # airflow.kubernetes is an expensive import, locally import it here to
         # speed up load times of the kubernetes_executor module.
@@ -169,9 +169,9 @@ def clear_not_launched_queued_tasks(self, session: Session = NEW_SESSION) -> Non
             if pod_list:
                 continue
             # Fallback to old style of using execution_date
-            kwargs["label_selector"] = (
-                f"{base_label_selector}," f"execution_date={self._make_safe_label_value(ti.execution_date)}"
-            )
+            kwargs[
+                "label_selector"
+            ] = f"{base_label_selector},execution_date={self._make_safe_label_value(ti.execution_date)}"
             pod_list = self._list_pods(kwargs)
             if pod_list:
                 continue
@@ -347,7 +347,6 @@ def _change_state(
     ) -> None:
         if TYPE_CHECKING:
             assert self.kube_scheduler
-        from airflow.models.taskinstance import TaskInstance
 
         if state == State.RUNNING:
             self.event_buffer[key] = state, None

diff --git a/airflow/kubernetes/kubernetes_helper_functions.py b/airflow/kubernetes/kubernetes_helper_functions.py
@@ -26,6 +26,7 @@
 
 from airflow.compat.functools import cache
 from airflow.configuration import conf
+
 if TYPE_CHECKING:
     from airflow.models.taskinstancekey import TaskInstanceKey