Add "timedOut" as job state in Viya

sassoftware · Jul 15, 2024 · 7be7439 · 7be7439
1 parent 87e1cf7
commit 7be7439
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/setup.cfg b/setup.cfg
@@ -1,6 +1,6 @@
 [metadata]
 name = sas-airflow-provider
-version = 0.0.15
+version = 0.0.16
 author = SAS
 author_email = [email protected]
 description = Enables execution of Studio Flows and Jobs from Airflow

diff --git a/src/sas_airflow_provider/operators/sas_studio.py b/src/sas_airflow_provider/operators/sas_studio.py
@@ -238,6 +238,9 @@ def execute(self, context):
 
         elif job_state == "timed out":
             raise AirflowException("SAS Studio Execution has timed out. See log for details ")
+
+        elif job_state == "timedOut":
+            raise AirflowException("SAS Studio Execution has timed out. See log for details ")
 
         return 1