From a371c8fdd6a748098c8a701d20db4b3c59176afd Mon Sep 17 00:00:00 2001 From: Stefan Huber Date: Fri, 17 May 2013 16:47:18 +0200 Subject: [PATCH] Show exit code after jobs was processed --- paralleljobs.py | 14 +++++++++----- 1 file changed, 9 insertions(+), 5 deletions(-) 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, \ -- 2.30.2