diff --git a/airflow/models.py b/airflow/models.py index e4a50bc476f98..9d1d64ee73e9e 100755 --- a/airflow/models.py +++ b/airflow/models.py @@ -5282,6 +5282,9 @@ def verify_integrity(self, session=None): continue if task.task_id not in task_ids: + Stats.incr( + "task_instance_created-{}".format(task.__class__.__name__), + 1, 1) ti = TaskInstance(task, self.execution_date) session.add(ti)