projects
/
paralleljobs.git
/ commitdiff
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
a2f946a
)
Add option -n
author
Stefan Huber <shuber@sthu.org>
Wed, 8 May 2013 07:35:08 +0000
(09:35 +0200)
committer
Stefan Huber <shuber@sthu.org>
Wed, 8 May 2013 07:35:08 +0000
(09:35 +0200)
paralleljobs.py
patch
|
blob
|
history
diff --git
a/paralleljobs.py
b/paralleljobs.py
index f2e6eea15828b9c080945232db2b4d8e10c8dd92..baf79651b101056abf7eb20513c73303e8cbf695 100755
(executable)
--- a/
paralleljobs.py
+++ b/
paralleljobs.py
@@
-166,6
+166,7
@@
COMMANDS:
OPTIONS:
-d database the database to process
OPTIONS:
-d database the database to process
+ -n num in -w mode, only perform num-many jobs
-p cols-def create properties table with SQL column spec
-v print output of the job's command
-p cols-def create properties table with SQL column spec
-v print output of the job's command
@@
-206,9
+207,10
@@
if __name__ == "__main__":
propdef = None
work = False
status = False
propdef = None
work = False
status = False
+ numjobs = None
try:
try:
- opts, args = getopt.getopt(sys.argv[1:], "hd:c:p:wsv")
+ opts, args = getopt.getopt(sys.argv[1:], "hd:c:p:wsv
n:
")
for opt, arg in opts:
if opt == "-h":
for opt, arg in opts:
if opt == "-h":
@@
-226,6
+228,8
@@
if __name__ == "__main__":
status = True
elif opt == "-v":
verbose = True
status = True
elif opt == "-v":
verbose = True
+ elif opt == "-n":
+ numjobs = int(arg)
else:
print("Unknown option '", opt, "'.")
else:
print("Unknown option '", opt, "'.")
@@
-254,12
+258,15
@@
if __name__ == "__main__":
insertJobs(conn, cmds)
if work:
insertJobs(conn, cmds)
if work:
- while True:
+ n = 0
+ while not numjobs or n < numjobs:
+
jobid = getNextJobId(conn)
if jobid == None:
print("All jobs have been started.")
break
processJob(conn, jobid)
jobid = getNextJobId(conn)
if jobid == None:
print("All jobs have been started.")
break
processJob(conn, jobid)
+ n += 1
conn.close()
conn.close()