From: Stefan Huber Date: Fri, 17 May 2013 14:47:18 +0000 (+0200) Subject: Show exit code after jobs was processed X-Git-Tag: v1.1~1 X-Git-Url: https://git.sthu.org/?p=paralleljobs.git;a=commitdiff_plain;h=a371c8fdd6a748098c8a701d20db4b3c59176afd Show exit code after jobs was processed --- diff --git a/paralleljobs.py b/paralleljobs.py index 5c309cd..463afbe 100755 --- a/paralleljobs.py +++ b/paralleljobs.py @@ -1,4 +1,4 @@ -#!/usr/bin/env python3 +#!/usr/bin/env python """ A simple tool to run jobs from a database in parallel.""" __author__ = "Stefan Huber" @@ -74,7 +74,7 @@ def runCmd(cmd): exitcode = proc.wait() if verbose: - print(out, err) + print out, err return exitcode, out, err @@ -84,9 +84,13 @@ def processJob(conn, jobid): c.execute("SELECT cmd FROM jobs WHERE id=?", (jobid,)) cmd, = c.fetchone() - print("Process job %d: %s" % (jobid, cmd)) - + print "Job %d: '%s'..." % (jobid, cmd), ec, out, err = runCmd(cmd) + if ec==0: + print " [OK]" + else: + print " [FAILED: %d]" % ec + c.execute("UPDATE jobs SET exitcode=?, done=1 WHERE id=?;", (ec, jobid)) propstr = [] @@ -130,7 +134,7 @@ def createSchema(conn): # Create table, if necessary c.execute("SELECT count(name) FROM sqlite_master WHERE name='jobs';") if c.fetchone() == (0,): - print("Creating jobs table.") + print "Creating jobs table." conn.execute("CREATE TABLE jobs ( \ id INTEGER PRIMARY KEY AUTOINCREMENT, \ cmd STRING NOT NULL, \