Added better options to manage celeryd

This commit is contained in:
2011-06-02 09:29:09 +01:00
parent e485f2d096
commit 666e8ab1ed

10
fabfile.py vendored
View File

@@ -153,12 +153,20 @@ def stop_celeryd():
with cd('%(path)s/dreddit-auth/' % env): with cd('%(path)s/dreddit-auth/' % env):
if exists('logs/celeryd.pid'): if exists('logs/celeryd.pid'):
run('kill `cat logs/celeryd.pid`') run('kill -15 `cat logs/celeryd.pid`')
time.sleep(2) time.sleep(2)
run('rm -f logs/celeryd.pid') run('rm -f logs/celeryd.pid')
else: else:
warn('celeryd isn\'t running') warn('celeryd isn\'t running')
def kill_celeryd():
"""
Kills all Celeryd instances
"""
with cd('%(path)s/dreddit-auth/' % env):
run("ps auxww | grep celeryd | awk '{print $2}' | xargs kill -9")
def restart_celeryd(): def restart_celeryd():
""" """
Restart the celery daemon Restart the celery daemon