django - 我可以在运行时在 Task 上定义 celery 队列属性吗？

Question

用例:

class MyTask(Task):
    queue = 'default_queue'

    def run(self):
        # do work

通常我会运行以下将使用指定的“default_queue”。

MyTask.delay()

我需要做的是:

if hours_since_last_login > 24:
    MyTask.delay()   # using the queue 'high_priority_queue'
else:
    MyTask.delay()   # using the 'default_queue'

我知道我可以子类化 MyTask 来覆盖 queue 属性，但是有没有办法在运行时定义它？

这是以下正确的方法吗？

task = MyTask()
task.queue = 'high_priority_queue'
task.delay()

Answer 1

来自 IRC 上的 askol:

MyTask.apply_async(args=[], kwargs={}, queue='high_priority_queue')