diff --git a/airflow/models/taskinstance.py b/airflow/models/taskinstance.py index 9edb71d8e205c7..ef8b91b17dc53e 100644 --- a/airflow/models/taskinstance.py +++ b/airflow/models/taskinstance.py @@ -950,7 +950,10 @@ 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: + # 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 AirflowRescheduleException as reschedule_exception: