airflow-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davy...@apache.org
Subject incubator-airflow git commit: [AIRFLOW-349] Add metric for number of zombies killed
Date Thu, 21 Jul 2016 17:43:28 GMT
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.davydov@airbnb.com>
Authored: Thu Jul 21 10:43:22 2016 -0700
Committer: Dan Davydov <dan.davydov@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):


Mime
View raw message