From edea93e0beb93fe832af6ca76b3836b68b6066e2 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Franti=C5=A1ek=20Dvo=C5=99=C3=A1k?= Date: Wed, 4 Mar 2015 21:00:53 +0100 Subject: [PATCH] Fix inserting new jobs. --- jobs.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/jobs.py b/jobs.py index 359d629..00b3988 100755 --- a/jobs.py +++ b/jobs.py @@ -321,7 +321,7 @@ for id, job in jobs.iteritems(): if debug: print '[db] job %s updated' % id else: - st.execute("INSERT INTO job (id, user, status, start, finish) VALUES('%s', %s, %s)" %(id, job.user, job.status, dbint(job.start), dbint(job.finish))) + st.execute("INSERT INTO job (id, user, status, start, finish) VALUES('%s', '%s', '%s', %s, %s)" %(id, job.user, job.status, dbint(job.start), dbint(job.finish))) if debug: print '[db] job %s inserted' % id if job.mapred: if data and data[3] == job.mapred['submitTime'] and data[8] == job.mapred['mapsTotal'] and data[9] == job.mapred['reducesTotal']: -- 1.8.2.3