X-Git-Url: http://git.sthu.org/?p=paralleljobs.git;a=blobdiff_plain;f=paralleljobs.py;h=6eb92dda40b803a9543ea161360170e4f50ead0a;hp=baf79651b101056abf7eb20513c73303e8cbf695;hb=76576fca186993bcd55c521bd6018019fd0cc5d7;hpb=c9ac24f37d75d103df68fefde3d5cfe88d0ea939 diff --git a/paralleljobs.py b/paralleljobs.py index baf7965..6eb92dd 100755 --- a/paralleljobs.py +++ b/paralleljobs.py @@ -66,12 +66,13 @@ def runCmd(cmd): return exitcode, out, err def processJob(conn, jobid): - print("Process job %d" % (jobid)) c = conn.cursor() c.execute("SELECT cmd FROM jobs WHERE id=?", (jobid,)) cmd, = c.fetchone() + print("Process job %d: %s" % (jobid, cmd)) + ec, out, err = runCmd(cmd) c.execute("UPDATE jobs SET exitcode=?, done=1 WHERE id=?;", (ec, jobid))