This is an automated email from the ASF dual-hosted git repository.

potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git


The following commit(s) were added to refs/heads/main by this push:
     new 117a531cb0 Fix returned value when ShortCircuitOperator condition is 
falsy and there is not downstream tasks (#32623)
117a531cb0 is described below

commit 117a531cb05398e5021a02fd70a1d4d752b17bc0
Author: Hussein Awala <[email protected]>
AuthorDate: Sat Jul 15 11:16:01 2023 +0200

    Fix returned value when ShortCircuitOperator condition is falsy and there 
is not downstream tasks (#32623)
---
 airflow/operators/python.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/airflow/operators/python.py b/airflow/operators/python.py
index f7b9883eaf..622e901984 100644
--- a/airflow/operators/python.py
+++ b/airflow/operators/python.py
@@ -257,7 +257,7 @@ class ShortCircuitOperator(PythonOperator, SkipMixin):
 
         if not self.downstream_task_ids:
             self.log.info("No downstream tasks; nothing to do.")
-            return
+            return condition
 
         dag_run = context["dag_run"]
 

Reply via email to