@task
@needs('pavelib.prereqs.install_prereqs')
@cmdopts([('settings=', 's', 'Django settings')])
def celery(options):
 settings = getattr(options, 'settings', 'dev_with_worker')
 run_process(django_cmd('lms', settings, 'celery', 'worker', '--beat', '--loglevel=INFO', '--pythonpath=.'))

@ task @ needs ( 'pavelib.prereqs.install_prereqs' ) @ cmdopts ( [ ( 'settings=' , 's' , 'Django settings' ) ] ) def celery ( options ) : settings = getattr ( options , 'settings' , 'dev_with_worker' ) run_process ( django_cmd ( 'lms' , settings , 'celery' , 'worker' , '--beat' , '--loglevel=INFO' , '--pythonpath=.' ) )
runs celery workers .