From: Jean-Michel Nirgal Vourgère Date: Thu, 11 Nov 2010 01:14:06 +0000 (+0000) Subject: Removed obsolete --loop option from jobrunner X-Git-Url: https://git.nirgal.com/?p=ais.git;a=commitdiff_plain;h=e16cd28000c6645c5c415bc28bb0df1be24789ae Removed obsolete --loop option from jobrunner --- diff --git a/INSTALL b/INSTALL index df096db..958b606 100644 --- a/INSTALL +++ b/INSTALL @@ -75,7 +75,7 @@ python -m ais.inputs.run --db --background = Job queue runner ================== umask 002 -python -m ais.jobrunner --loop --daemon +python -m ais.jobrunner --daemon = Apache setup ============== diff --git a/bin/jobrunner.py b/bin/jobrunner.py index 577fabc..bb5aab3 100755 --- a/bin/jobrunner.py +++ b/bin/jobrunner.py @@ -90,9 +90,6 @@ def main(): parser.add_option('--daemon', action='store_true', dest='daemonize', default=False, help='runs as a daemon') - parser.add_option('--loop', - action='store_true', dest='loop', default=False, - help='keeps running forever') options, args = parser.parse_args() if args: @@ -121,23 +118,20 @@ def main(): # todo: pidfile= with import lockfile (squeeze) dctx.open() - if options.loop: - if os.path.exists(SOCK_FILENAME): - os.remove(SOCK_FILENAME) - server = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM) - server.bind(SOCK_FILENAME) - os.chmod(SOCK_FILENAME, 0777) - - while True: - r = runjob() - if r == 0: - server.recv(1024) # blocks - elif r == 1: - logging.error('Allready running?') - sys.exit(1) - # else loop now - else: - runjob() + if os.path.exists(SOCK_FILENAME): + os.remove(SOCK_FILENAME) + server = socket.socket(socket.AF_UNIX, socket.SOCK_DGRAM) + server.bind(SOCK_FILENAME) + os.chmod(SOCK_FILENAME, 0777) + + while True: + r = runjob() + if r == 0: + server.recv(1024) # blocks + elif r == 1: + logging.error('Allready running?') + sys.exit(1) + # else loop now if __name__ == '__main__': main()