|
@@ -69,11 +69,13 @@ def runcelery(*args, **options):
|
|
|
#CeleryCommand().handle_argv(['worker', '--app=desktop.celery', '--concurrency=1', '--loglevel=DEBUG'])
|
|
#CeleryCommand().handle_argv(['worker', '--app=desktop.celery', '--concurrency=1', '--loglevel=DEBUG'])
|
|
|
opts = ['runcelery', 'worker', '--app=' + options['app'], '--concurrency=' + str(options['concurrency']), '--loglevel=' + options['loglevel']]
|
|
opts = ['runcelery', 'worker', '--app=' + options['app'], '--concurrency=' + str(options['concurrency']), '--loglevel=' + options['loglevel']]
|
|
|
drop_privileges_if_necessary(CELERY_OPTIONS)
|
|
drop_privileges_if_necessary(CELERY_OPTIONS)
|
|
|
|
|
+
|
|
|
if conf.DEV.get():
|
|
if conf.DEV.get():
|
|
|
autoreload.main(celery_main, (opts,))
|
|
autoreload.main(celery_main, (opts,))
|
|
|
else:
|
|
else:
|
|
|
celery_main(opts)
|
|
celery_main(opts)
|
|
|
- LOG.error("Failed to exec '%s' with argument '%s'" % args)
|
|
|
|
|
|
|
+
|
|
|
|
|
+ LOG.info("Stopping command '%s'" % ' '.join(opts))
|
|
|
sys.exit(-1)
|
|
sys.exit(-1)
|
|
|
|
|
|
|
|
if __name__ == '__main__':
|
|
if __name__ == '__main__':
|