celeryd_init signal now has new "options" argument for command-line options

celery/apps/worker.py

@@ -130,7 +130,8 @@ class Worker(WorkController):
         # this signal can be used to set up configuration for
         # workers by name.
         signals.celeryd_init.send(
-            sender=self.hostname, instance=self, conf=self.app.conf,
+            sender=self.hostname, instance=self,
+            conf=self.app.conf, options=kwargs,
         )
 
     def on_after_init(self, purge=False, no_color=None,

celery/signals.py

@@ -45,7 +45,7 @@ task_failure = Signal(providing_args=[
 task_revoked = Signal(providing_args=[
     'request', 'terminated', 'signum', 'expired',
 ])
-celeryd_init = Signal(providing_args=['instance', 'conf'])
+celeryd_init = Signal(providing_args=['instance', 'conf', 'options'])
 celeryd_after_setup = Signal(providing_args=['instance', 'conf'])
 worker_init = Signal(providing_args=[])
 worker_process_init = Signal(providing_args=[])

docs/userguide/signals.rst

@@ -348,6 +348,11 @@ Provides arguments:
 * conf
     The configuration of the current app.
 
+* options
+
+    Options passed to the worker from command-line arguments (including
+    defaults).
+
 .. signal:: worker_init
 
 worker_init