Adding exit code stats

[paralleljobs.git] / paralleljobs.py

diff --git a/paralleljobs.py b/paralleljobs.py
index 465efdf777622f4e215b42960606e3714af89d61..5c309cd7e7118f677161ebbbd0e7519b81cb3727 100755 (executable)
--- a/paralleljobs.py
+++ b/paralleljobs.py
@@ -1,4 +1,4 @@
-#!/usr/bin/env python
+#!/usr/bin/env python3
 """ A simple tool to run jobs from a database in parallel."""
 
 __author__ = "Stefan Huber"
@@ -34,7 +34,6 @@ def printStatusInfo(conn):
     c.execute("SELECT sum(workloadestm) FROM jobs;")
     wltotal, = c.fetchone()
 
-    c.close()
 
     perdone = 0
     perwl = 0
@@ -46,6 +45,13 @@ def printStatusInfo(conn):
     print("%d (%.1f%%) of %d jobs and %.1f%% of the workload done. %d jobs are running." % \
             (nodone, perdone, nototal, perwl, nostarted-nodone))
 
+    print("Exit code stats:")
+    c.execute("SELECT exitcode, count(exitcode) AS cnt FROM jobs GROUP BY exitcode ORDER BY exitcode ASC;")
+    for code, cnt in c.fetchall():
+        print("  %3s: %6s  (%5.1f%%)" % (code, cnt, 100.0*float(cnt)/nodone))
+
+    c.close()
+
 def createPropertiesTable(conn, propdef):
     conn.execute("BEGIN EXCLUSIVE")
 
@@ -250,7 +256,7 @@ if __name__ == "__main__":
         print("No database given.")
         sys.exit(os.EX_USAGE)
 
-    conn = sqlite3.connect(dbfn)
+    conn = sqlite3.connect(dbfn, timeout=60)
     createSchema(conn)
 
     if status: