Repository: incubator-airflow Updated Branches: refs/heads/master 00a591f7b -> b6e609824
[AIRFLOW-349] Add metric for number of zombies killed Closes #1673 from aoen/ddavydov/metric_for_number_of_zombies_killed Project: http://git-wip-us.apache.org/repos/asf/incubator-airflow/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-airflow/commit/b6e60982 Tree: http://git-wip-us.apache.org/repos/asf/incubator-airflow/tree/b6e60982 Diff: http://git-wip-us.apache.org/repos/asf/incubator-airflow/diff/b6e60982 Branch: refs/heads/master Commit: b6e609824cb26bce1c9855f5d7e78a159ed03cc9 Parents: 00a591f Author: Dan Davydov <dan.davy...@airbnb.com> Authored: Thu Jul 21 10:43:22 2016 -0700 Committer: Dan Davydov <dan.davy...@airbnb.com> Committed: Thu Jul 21 10:43:22 2016 -0700 ---------------------------------------------------------------------- airflow/models.py | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-airflow/blob/b6e60982/airflow/models.py ---------------------------------------------------------------------- diff --git a/airflow/models.py b/airflow/models.py index 1b61318..7193765 100644 --- a/airflow/models.py +++ b/airflow/models.py @@ -339,6 +339,7 @@ class DagBag(LoggingMixin): ti.handle_failure("{} killed as zombie".format(ti)) self.logger.info( 'Marked zombie job {} as failed'.format(ti)) + Stats.incr('zombies_killed') session.commit() def bag_dag(self, dag, parent_dag, root_dag):
