From 9659dec4f7dc12b5e2990e220756abb292d25023 Mon Sep 17 00:00:00 2001 From: Andrew Kenworthy Date: Thu, 14 Nov 2024 14:26:10 +0100 Subject: [PATCH] remove unknown from failure states with comment --- .../airflow/examples/example_spark_kubernetes_sensor.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/docs/modules/airflow/examples/example_spark_kubernetes_sensor.py b/docs/modules/airflow/examples/example_spark_kubernetes_sensor.py index f67a28a5..4ddf3afd 100644 --- a/docs/modules/airflow/examples/example_spark_kubernetes_sensor.py +++ b/docs/modules/airflow/examples/example_spark_kubernetes_sensor.py @@ -25,7 +25,9 @@ class SparkKubernetesSensor(BaseSensorOperator): # <3> template_fields = ("application_name", "namespace") - FAILURE_STATES = ("Failed", "Unknown") + # See https://github.com/stackabletech/spark-k8s-operator/pull/460/files#diff-d737837121132af6b60f50279a78464b05dcfd06c05d1d090f4198a5e962b5f6R371 + # Unknown is set immediately so it must be excluded from the failed states. + FAILURE_STATES = "Failed" SUCCESS_STATES = "Succeeded" def __init__(