|
|
@@ -18,16 +18,17 @@ from celery.bin.base import Option
|
|
|
app = Celery('tasks', backend ='redis://172.104.92.245', broker='redis://172.104.92.245')
|
|
|
qname=None
|
|
|
|
|
|
-app.user_options['preload'].add(Option(
|
|
|
- '--jared', action='store_true',
|
|
|
- help='Enable our external monitoring utility, blahblah',
|
|
|
-))
|
|
|
+def add_preload_options(parser):
|
|
|
+ parser.add_argument(
|
|
|
+ "-Z", "--template", default="default", help="Configuration template to use.",
|
|
|
+ )
|
|
|
+
|
|
|
+app.user_options["preload"].add(add_preload_options)
|
|
|
+
|
|
|
|
|
|
@signals.user_preload_options.connect
|
|
|
-def handle_preload_options(options, **kwargs):
|
|
|
- if options['jared']:
|
|
|
- print(options)
|
|
|
-# enable_monitoring()
|
|
|
+def on_preload_parsed(options, **kwargs):
|
|
|
+ print(options["template"])
|
|
|
|
|
|
@celeryd_init.connect
|
|
|
def configure_workers(sender=None, **kwargs):
|
