From 595507616b873f7a5bc6a276b71ad9f735d4db53 Mon Sep 17 00:00:00 2001 From: Rajat Srivastava Date: Fri, 29 Nov 2019 15:15:40 +0530 Subject: [PATCH] [CX-16266] Change with reference to 1a4c164 commit in open source Due to refactoring of models.py in open source, made this changes instead of cherry picking the commit. --- airflow/models.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/airflow/models.py b/airflow/models.py index 757913b2dd36e..b710820f570f5 100755 --- a/airflow/models.py +++ b/airflow/models.py @@ -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: