[CX-16266] Change with reference to 1a4c164 commit in open source (#25)

Due to refactoring of models.py in open source, made this changes instead of cherry picking the commit.
twitter-forks · Dec 3, 2019 · 67a4d1c · 67a4d1c
1 parent 51b1aee
commit 67a4d1c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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: