Django celery在完成前一个实例的设置持续时间后开始定期任务

Question

目前我有一个周期性的任务，每30分钟运行一次。任务本身有时需要30多分钟才能完成。在

如何更改定期任务在上次运行完成后30分钟运行？在

@periodic_task(run_every=timedelta(minutes=30), queue='activities', options={'queue': 'activities'})
def pull_activities_frequent_adaptors():
    adaptors_queryset = TrackingAppAdaptor.objects.adaptors_that_pull_activities_frequently()
    pull_activities_from_adaptors(adaptors_queryset)

Answer 1

对不起，你不能这么做。在

由于有多个worker执行该作业，因此您实际上需要确保没有工人正在运行上一个任务。在

你能做什么：

1. 使用celery backend可以监视是否仍有任务正在进行，而不执行当前任务。这将允许您创建一个只有一个任务被执行的情况。

2. 当任务完成后，您可以创建一个触发器来发送等待30分钟的新任务，您可以使用ETA