|
@@ -167,6 +167,10 @@ class Worker(configurated):
|
|
|
self.set_process_status('-active-')
|
|
|
|
|
|
self.redirect_stdouts_to_logger()
|
|
|
+ # this signal can be used to e.g. change queues after
|
|
|
+ # the -Q option has been applied.
|
|
|
+ signals.celeryd_after_setup.send(sender=self.hostname, instance=self,
|
|
|
+ conf=self.app.conf)
|
|
|
try:
|
|
|
self.run_worker()
|
|
|
except IGNORE_ERRORS:
|