Show More
@@ -33,4 +33,4 b" os.environ['CELERY_LOADER'] = CELERYPYLO" | |||
|
33 | 33 | import celery.app as app |
|
34 | 34 | import celery.result as result |
|
35 | 35 | from celery.task import task |
|
36 |
from celery.bin import |
|
|
36 | from celery.bin import worker |
@@ -24,7 +24,7 b' class Command(BasePasterCommand):' | |||
|
24 | 24 | |
|
25 | 25 | def update_parser(self): |
|
26 | 26 | from kallithea.lib import celerypylons |
|
27 |
cmd = celerypylons. |
|
|
27 | cmd = celerypylons.worker.worker(celerypylons.app.app_or_default()) | |
|
28 | 28 | for x in cmd.get_options(): |
|
29 | 29 | self.parser.add_option(x) |
|
30 | 30 | |
@@ -42,5 +42,5 b' class Command(BasePasterCommand):' | |||
|
42 | 42 | kallithea.CELERY_ON = CELERY_ON |
|
43 | 43 | |
|
44 | 44 | load_rcextensions(config['here']) |
|
45 |
cmd = celerypylons. |
|
|
45 | cmd = celerypylons.worker.worker(celerypylons.app.app_or_default()) | |
|
46 | 46 | return cmd.run(**vars(self.options)) |
General Comments 0
You need to be logged in to leave comments.
Login now