Fixes #30. End task when finished with errors.

damavis · Mar 24, 2023 · 0418f96 · 0418f96
1 parent 42d9416
commit 0418f96
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/airflow_pentaho/operators/carte.py b/airflow_pentaho/operators/carte.py
@@ -205,3 +205,7 @@ def execute(self, context):  # pylint: disable=unused-argument
         if 'error_desc' in status and status['error_desc']:
             self.log.error(self.LOG_TEMPLATE, status['error_desc'], self.trans)
             raise AirflowException(status['error_desc'])
+
+        if status_desc in self.ERRORS_STATUSES:
+            self.log.error(self.LOG_TEMPLATE, status['status_desc'], self.trans)
+            raise AirflowException(status['status_desc'])
diff --git a/setup.py b/setup.py
@@ -24,7 +24,7 @@
 
 setup(
     name='airflow-pentaho-plugin',
-    version='1.0.20',
+    version='1.0.21',
     license='Apache 2.0',
     author='Damavis',
     author_email='[email protected]',