(k8s/pod_generator.py): changed the function construct_pod() to use a…

…dd_unique_suffix before it used a deprecated one
apache · Apr 3, 2024 · d8afed6 · d8afed6
1 parent 15e4259
commit d8afed6
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/airflow/providers/cncf/kubernetes/pod_generator.py b/airflow/providers/cncf/kubernetes/pod_generator.py
@@ -46,7 +46,8 @@
 from airflow.providers.cncf.kubernetes.kubernetes_helper_functions import (
  POD_NAME_MAX_LENGTH,
  add_pod_suffix,
- rand_str,
+ add_unique_suffix,
+ rand_str
 )
 from airflow.providers.cncf.kubernetes.pod_generator_deprecated import (
  PodDefaults,
@@ -397,7 +398,7 @@ def construct_pod(
  UserWarning,
  stacklevel=2,
  )
- pod_id = add_pod_suffix(pod_name=pod_id, max_len=POD_NAME_MAX_LENGTH)
+ pod_id = add_unique_suffix(name=pod_id, max_len=POD_NAME_MAX_LENGTH)
  try:
  image = pod_override_object.spec.containers[0].image # type: ignore
  if not image: