diff --git a/mount-dags-gitsync/dags/stackable/spark_kubernetes_sensor.py b/mount-dags-gitsync/dags/stackable/spark_kubernetes_sensor.py index 8a1c2aa4fb65b33f2b9feef87cc85b457758008a..2936ecfb0632927ead788d163985e5cfd3427ab4 100644 --- a/mount-dags-gitsync/dags/stackable/spark_kubernetes_sensor.py +++ b/mount-dags-gitsync/dags/stackable/spark_kubernetes_sensor.py @@ -7,7 +7,8 @@ from airflow.providers.cncf.kubernetes.hooks.kubernetes import KubernetesHook class SparkKubernetesSensor(BaseSensorOperator): template_fields = ("application_name", "namespace") - FAILURE_STATES = ("Failed", "Unknown") + #FAILURE_STATES = ("Failed", "Unknown") + FAILURE_STATES = ("Failed") SUCCESS_STATES = "Succeeded" def __init__(