This is an automated email from the ASF dual-hosted git repository. potiuk pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push: new b59cef1c83 Moves airflow import in deprecated pod_generator to local (#39062) b59cef1c83 is described below commit b59cef1c8374d53e1ffdeb46c94e6c9ff30c239d Author: Jarek Potiuk <ja...@potiuk.com> AuthorDate: Tue Apr 16 15:20:53 2024 +0200 Moves airflow import in deprecated pod_generator to local (#39062) The import might be invoked when K8S executor starts with sentry on and it might lead to circular imports Related: #31442 --- airflow/providers/cncf/kubernetes/pod_generator_deprecated.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/airflow/providers/cncf/kubernetes/pod_generator_deprecated.py b/airflow/providers/cncf/kubernetes/pod_generator_deprecated.py index 92baf41e68..9a978cbd08 100644 --- a/airflow/providers/cncf/kubernetes/pod_generator_deprecated.py +++ b/airflow/providers/cncf/kubernetes/pod_generator_deprecated.py @@ -31,8 +31,6 @@ import uuid import re2 from kubernetes.client import models as k8s -from airflow.utils.hashlib_wrapper import md5 - MAX_POD_ID_LEN = 253 MAX_LABEL_LEN = 63 @@ -71,6 +69,8 @@ def make_safe_label_value(string): way from the original value sent to this function, then we need to truncate to 53 chars, and append it with a unique hash. """ + from airflow.utils.hashlib_wrapper import md5 + safe_label = re2.sub(r"^[^a-z0-9A-Z]*|[^a-zA-Z0-9_\-\.]|[^a-z0-9A-Z]*$", "", string) if len(safe_label) > MAX_LABEL_LEN or string != safe_label: