diff --git a/airflow_pentaho/operators/carte.py b/airflow_pentaho/operators/carte.py
index bfd5552..71cc2ab 100644
--- 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
index f47d6e0..bae61a4 100644
--- 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='info@damavis.com',