Skip to content

Commit

Permalink
[CX-16266] Change with reference to 1a4c164 commit in open source (ap…
Browse files Browse the repository at this point in the history
…ache#25)

Due to refactoring of models.py in open source, made this changes instead of cherry picking the commit.
  • Loading branch information
rajatsri28 authored and msumit committed Dec 3, 2019
1 parent 51b1aee commit 67a4d1c
Showing 1 changed file with 5 additions and 1 deletion.
6 changes: 5 additions & 1 deletion airflow/models.py
Original file line number Diff line number Diff line change
Expand Up @@ -1660,7 +1660,11 @@ def signal_handler(signum, frame):
Stats.incr('ti_successes')
self.refresh_from_db(lock_for_update=True)
self.state = State.SUCCESS
except AirflowSkipException:
except AirflowSkipException as e:
# This change is in reference to [AIRFLOW-5653][CX-16266]
# log only if exception has any arguments to prevent log flooding
if e.args:
self.log.info(e)
self.refresh_from_db(lock_for_update=True)
self.state = State.SKIPPED
except AirflowException as e:
Expand Down

0 comments on commit 67a4d1c

Please sign in to comment.