在队列中设置队列名称

Question

我想调整任务队列名称，管道任务在其上运行。 我认为这可以通过以下途径实现：

myPipeline = SumPipeline(future1, future2)
myPipeline.start(queue_name='myqueue')

但是如果我不手动启动管道，但它是由另一个管道生成的，会发生什么呢？例如：

class RootPipeline(pipeline.Pipeline):

    def run(self):
        yield SumPipeline(future1, future2)

对于产生的管道RootPipeline和产生的管道SumPipeline，是否可以有单独的任务队列？如果是，怎么做？你知道吗

谢谢。你知道吗

Answer 1

我对Python代码不太熟悉，但我想知道在sumpippeline中重写queue\u name以返回您希望它运行的队列是否不会起作用（因为我看不到任何其他方法）。你知道吗

class SumPipeline(pipeline.Pipeline):
  ....
  @property
  def queue_name(self):
    return "...."