Fix PythonVirtualenvOperator tests (#36367)

(cherry picked from commit af4b51c)
apache · Jan 11, 2024 · 8317580 · 8317580
1 parent d80d6a1
commit 8317580
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/airflow/operators/python.py b/airflow/operators/python.py
@@ -472,6 +472,9 @@ def _execute_python_callable_in_subprocess(self, python_path: Path):
                 else:
                     raise
 
+            if 0 in self.skip_on_exit_code:
+                raise AirflowSkipException("Process exited with code 0. Skipping.")
+
             return self._read_result(output_path)
 
     def determine_kwargs(self, context: Mapping[str, Any]) -> Mapping[str, Any]: