uranusjr commented on a change in pull request #17421:
URL: https://github.com/apache/airflow/pull/17421#discussion_r737011293
##
File path: airflow/operators/python.py
##
@@ -185,16 +186,37 @@ def execute(self, context: Dict):
class ShortCircuitOperator(PythonOperator, SkipMi
uranusjr commented on a change in pull request #17421:
URL: https://github.com/apache/airflow/pull/17421#discussion_r734289668
##
File path: airflow/operators/python.py
##
@@ -185,16 +186,37 @@ def execute(self, context: Dict):
class ShortCircuitOperator(PythonOperator, SkipMi
uranusjr commented on a change in pull request #17421:
URL: https://github.com/apache/airflow/pull/17421#discussion_r733807930
##
File path: airflow/operators/python.py
##
@@ -185,16 +186,37 @@ def execute(self, context: Dict):
class ShortCircuitOperator(PythonOperator, SkipMi
uranusjr commented on a change in pull request #17421:
URL: https://github.com/apache/airflow/pull/17421#discussion_r690936002
##
File path: airflow/operators/python.py
##
@@ -26,6 +26,11 @@
from textwrap import dedent
from typing import Any, Callable, Dict, Iterable, List, O
uranusjr commented on a change in pull request #17421:
URL: https://github.com/apache/airflow/pull/17421#discussion_r690937723
##
File path: airflow/operators/python.py
##
@@ -203,13 +220,26 @@ def execute(self, context: Dict):
self.log.info('Proceeding with downst
uranusjr commented on a change in pull request #17421:
URL: https://github.com/apache/airflow/pull/17421#discussion_r690936498
##
File path: airflow/operators/python.py
##
@@ -185,16 +190,28 @@ def execute(self, context: Dict):
class ShortCircuitOperator(PythonOperator, SkipMi
uranusjr commented on a change in pull request #17421:
URL: https://github.com/apache/airflow/pull/17421#discussion_r690936002
##
File path: airflow/operators/python.py
##
@@ -26,6 +26,11 @@
from textwrap import dedent
from typing import Any, Callable, Dict, Iterable, List, O
uranusjr commented on a change in pull request #17421:
URL: https://github.com/apache/airflow/pull/17421#discussion_r690121805
##
File path: airflow/operators/python.py
##
@@ -185,16 +185,27 @@ def execute(self, context: Dict):
class ShortCircuitOperator(PythonOperator, SkipMi