Skeleton for celeryctl

bin/celeryctl

@@ -0,0 +1,10 @@
+#!/usr/bin/env python
+import sys
+from celery.bin.celeryctl import celery_control, parse_options
+
+if __name__ == "__main__":
+    options, values = parse_options(sys.argv[1:])
+    celery_control(*values, **dict(options))
+
+
+

bin/celeryd

@@ -1,12 +1,7 @@
 #!/usr/bin/env python
 import sys
-from celery.bin.celeryd import main, parse_options
+from celery.bin.celeryd import run_worker, parse_options
 
 if __name__ == "__main__":
     options = parse_options(sys.argv[1:])
-    main(concurrency=options.concurrency,
-         daemon=options.daemon,
-         logfile=options.logfile,
-         loglevel=options.loglevel,
-         pidfile=options.pidfile,
-         queue_wakeup_after=options.queue_wakeup_after)
+    run_worker(**options)

celery/bin/celeryctl.py

@@ -0,0 +1,22 @@
+import os
+import sys
+sys.path.append(os.getcwd())
+django_project_dir = os.environ.get("DJANGO_PROJECT_DIR")
+if django_project_dir:
+    sys.path.append(django_project_dir)
+from django.conf import settings
+import optparse
+
+OPTION_LIST = ()
+
+
+def parse_options(arguments):
+    """Parse the available options to ``celeryctl``."""
+    parser = optparse.OptionParser(option_list=OPTION_LIST)
+    options, values = parser.parse_args(arguments)
+    return options, values
+
+
+def celery_control(*args, **kwargs):
+    print("ARGS: %s" % args)
+    print("KWARGS: %s" % kwargs)

setup.py

@@ -60,7 +60,7 @@ def run(self):
     url=celery.__homepage__,
     platforms=["any"],
     packages=find_packages(exclude=['ez_setup']),
-    scripts=["bin/celeryd"],
+    scripts=["bin/celeryd", "bin/celeryctl"],
     zip_safe=False,
     install_requires=[
         'carrot>=0.4.1',