Skip to content

Commit 67a4d1c

Browse files
rajatsri28msumit
authored andcommitted
[CX-16266] Change with reference to 1a4c164 commit in open source (twitter-forks#25)
Due to refactoring of models.py in open source, made this changes instead of cherry picking the commit.
1 parent 51b1aee commit 67a4d1c

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

airflow/models.py

+5-1
Original file line numberDiff line numberDiff line change
@@ -1660,7 +1660,11 @@ def signal_handler(signum, frame):
16601660
Stats.incr('ti_successes')
16611661
self.refresh_from_db(lock_for_update=True)
16621662
self.state = State.SUCCESS
1663-
except AirflowSkipException:
1663+
except AirflowSkipException as e:
1664+
# This change is in reference to [AIRFLOW-5653][CX-16266]
1665+
# log only if exception has any arguments to prevent log flooding
1666+
if e.args:
1667+
self.log.info(e)
16641668
self.refresh_from_db(lock_for_update=True)
16651669
self.state = State.SKIPPED
16661670
except AirflowException as e:

0 commit comments

Comments
 (0)