你应该能够以这种方式运行它.
worker = app.Worker( hostname=hostname, queues=[hostname], optimization='fair' ) worker.start()