Celery Task apply_async 行为不正确

Question

调用以下代码

 tasks.update_address_location.apply_async((address_obj.id), countdown = 10)

但是任务会立即在队列中执行。它的工作原理也必须排除我排除的其他可能性。认为有人可能有答案

capp = Celery('async', backend='redis://localhost:6379/0',
              broker='redis://localhost:6379/0', include=['app.async.tasks'])

# Optional configuration, see the application user guide.
capp.config_from_object(celeryconfig)
capp.conf.update(
    CELERY_TASK_RESULT_EXPIRES=3600,
)

if __name__ == '__main__':
    capp.start()

芹菜是这样称呼的：

celery multi stop worker  -A app.async.celery_app:capp --beat --loglevel=debug --pidfile=celery.pid --logfile=celery.log

celery.log中的输出一致且成功，但没有延迟。

Answer 1

A quirkof python - (x) == x - 具有一个元素的元组必须包含一个逗号 - (x,)

这样做：

apply_async((address_obj.id,), {}, countdown=10)

Celery Task apply_async 行为不正确

Celery Task apply_async behaviours incorrectly

python

celery