BugFix: Using json string in template_field causes issue with K8s O…

…perators (#16930) closes apache/airflow#16922 Because we simply check if fields in template_field ends with `template_ext`, this was causing issues if the str ends with json, in which case Airflow would try to search for file instead of using the string GitOrigin-RevId: b2c66e45b7c27d187491ec6a1dd5cc92ac7a1e32
GoogleCloudPlatform · Jul 10, 2022 · f3d5c61 · f3d5c61
1 parent fa3dabb
commit f3d5c61
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py b/airflow/providers/cncf/kubernetes/operators/kubernetes_pod.py
@@ -172,7 +172,7 @@ class KubernetesPodOperator(BaseOperator):
         'pod_template_file',
     )
 
-    template_ext = ('yaml', 'yml', 'json')
+    template_ext = ('.yaml', '.yml', '.json')
 
     # fmt: off
     def __init__(

diff --git a/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py b/airflow/providers/cncf/kubernetes/operators/spark_kubernetes.py
@@ -43,7 +43,7 @@ class SparkKubernetesOperator(BaseOperator):
     """
 
     template_fields = ['application_file', 'namespace']
-    template_ext = ('yaml', 'yml', 'json')
+    template_ext = ('.yaml', '.yml', '.json')
     ui_color = '#f4a460'
 
     def __init__(