X-Git-Url: http://git.sthu.org/?p=paralleljobs.git;a=blobdiff_plain;f=paralleljobs.py;h=6a1da0df60929f5aa29367fc1f5c06c1a0bc9b45;hp=baf79651b101056abf7eb20513c73303e8cbf695;hb=7eb919804d24d6e7f516dbe230251150eae45b25;hpb=c9ac24f37d75d103df68fefde3d5cfe88d0ea939 diff --git a/paralleljobs.py b/paralleljobs.py index baf7965..6a1da0d 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)) @@ -161,14 +162,14 @@ Usage: COMMANDS: -c cmdfn add jobs from the file with list of commands -h print this text - -s print status information - -w work on the database + -s print progress information + -w do work and process jobs OPTIONS: -d database the database to process - -n num in -w mode, only perform num-many jobs + -n num in -w mode, only process num-many jobs -p cols-def create properties table with SQL column spec - -v print output of the job's command + -v verbose output Commands may be combined in one call of {0}.