Fix AirflowSkipException message raised by BashOperator

apache · Dec 21, 2023 · 7006587 · 7006587
1 parent 0b32613
commit 7006587
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/airflow/operators/bash.py b/airflow/operators/bash.py
@@ -160,7 +160,7 @@ def __init__(
             skip_on_exit_code
             if isinstance(skip_on_exit_code, Container)
             else [skip_on_exit_code]
-            if skip_on_exit_code
+            if skip_on_exit_code is not None
             else []
         )
         self.cwd = cwd
@@ -235,8 +235,8 @@ def execute(self, context: Context):
             output_encoding=self.output_encoding,
             cwd=self.cwd,
         )
-        if self.skip_on_exit_code is not None and result.exit_code in self.skip_on_exit_code:
-            raise AirflowSkipException(f"Bash command returned exit code {self.skip_on_exit_code}. Skipping.")
+        if result.exit_code in self.skip_on_exit_code:
+            raise AirflowSkipException(f"Bash command returned exit code {result.exit_code}. Skipping.")
         elif result.exit_code != 0:
             raise AirflowException(
                 f"Bash command failed. The command returned a non-zero exit code {result.exit_code}."