From 9d3c179da3d5c4f585ee0d74d9235597b1472a05 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Franti=C5=A1ek=20Dvo=C5=99=C3=A1k?= Date: Thu, 5 Mar 2015 12:46:47 +0100 Subject: [PATCH] Fetch details, of not found in the database. --- jobs.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/jobs.py b/jobs.py index c77a3f7..b49549d 100755 --- a/jobs.py +++ b/jobs.py @@ -344,6 +344,12 @@ for id, job in jobs.iteritems(): if debug >= 2: print '[db] job %s yarn updated' % id changed = 1 + # check for details in DB + st.execute('SELECT * FROM jobnodes WHERE jobid=%s', id) + data = st.fetchone() + if not data: + changed = 1 + # get details (intensive!), if new job or any other difference jobnodes = dict() if job.mapred and (not db or changed): -- 1.8.2.3