我想做两件事
app.steps['worker'].add(LoadConfig)
完美无缺
但我无法进行 SetQueue 启动步骤
只是我的 SetQueue 现在看起来像:
class SetQueue(bootsteps.StartStopStep):
requires = (Consumer, )
def start(self, parent, **kwargs):
parent.add_task_queue('q_name', exchange='q_name', routing_key='q_name')
app.steps['consumer'].add(SetQueue)
Run Code Online (Sandbox Code Playgroud)
它不起作用。
我认为我的问题是我不明白 - 在什么时候(requires=(???, )) 可以添加队列。