Fixes #30. End task when finished with errors.

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

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/airflow_pentaho/operators/carte.py b/airflow_pentaho/operators/carte.py
@@ -198,7 +198,7 @@ def execute(self, context):  # pylint: disable=unused-argument
             self.log.info(self.LOG_TEMPLATE, status_desc, self.trans)
             self._log_logging_string(status['logging_string'])
 
-            if status_desc not in self.FINISHED_STATUSES:
+            if status_desc not in self.END_STATUSES:
                 self.log.info('Sleeping 5 seconds before ask again')
                 time.sleep(5)
 

diff --git a/setup.py b/setup.py
@@ -24,7 +24,7 @@
 
 setup(
     name='airflow-pentaho-plugin',
-    version='1.0.19',
+    version='1.0.20',
     license='Apache 2.0',
     author='Damavis',
     author_email='[email protected]',