0

countdown キーワードを使用して呼び出すセロリ タスクがあります。

def plan_my_task():
    countdown = some_computation_function()     #result is a positive integer
    res = my_task.apply_async(args=[some_arg], countdown=countdown)

@task
def my_task(some_arg):
    do_something()

私のログに次のようなものが表示されます

[2013-11-14 01:22:31,516: INFO/MainProcess] Received task: my_module.my_task[d5d36a59-b88a-43cb-b7ac-bf0737cdab2c] eta:[2013-11-14 01:16:17.513310+01:00]

ご覧のとおり、eta は現在の時刻よりも前に設定されています。

私はセロリ3.1を使用しています。

4

1 に答える 1