如何立即运行芹菜时间表？

Question

我有一个这样配置的芹菜时间表：

CELERYBEAT_SCHEDULE = {
    "runs-every-30-seconds": {
        "task": "tasks.refresh",
        "schedule": timedelta(hours=1)
    },
}

经过测试，我发现这个时间表是在 1 小时后开始的，但我想立即运行这个时间表，并在 1 小时后再次运行。

Answer 1

如果您的意思是在启动时，请在AppConfig.ready()（django 1.7 中的新功能）中执行：

# my_app/__init__.py:

class MyAppConfig(AppConfig):
    def ready(self):
        tasks.refresh.delay()

另见：https://docs.djangoproject.com/en/1.7/ref/applications/#module-django.apps

如果您只是为了测试而这样做，我宁愿直接调用/延迟任务而不是测试 celery 调度程序本身。