From 025ca92da1ce66df0f5e2e7aafea134aeb526f39 Mon Sep 17 00:00:00 2001 From: Daniel Standish <15932138+dstandish@users.noreply.github.com> Date: Tue, 14 May 2024 10:52:41 -0700 Subject: [PATCH] fix typing --- .../cncf/kubernetes/executors/kubernetes_executor_utils.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py index 8447c8dad7dbc..b8235bb5ac49b 100644 --- a/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py +++ b/airflow/providers/cncf/kubernetes/executors/kubernetes_executor_utils.py @@ -139,7 +139,7 @@ def _run( ) -> str | None: self.log.info("Event: and now my watch begins starting at resource_version: %s", resource_version) - kwargs: dict[str:Any] = {"label_selector": f"airflow-worker={scheduler_job_id}"} + kwargs: dict[str, Any] = {"label_selector": f"airflow-worker={scheduler_job_id}"} if resource_version: kwargs["resource_version"] = resource_version if kube_config.kube_client_request_args: