Il existe une bibliothèque appelée celery_once. Le mécanisme derrière elle consiste à définir un verrouillage de tâche avec le nom de la tâche dans redis. Lorsqu'une tâche est en cours d'exécution, la même tâche ne peut pas être déclenchée à nouveau.
Lorsqu'une tâche est déclenchée, s'il s'avère que la tâche a déjà un verrou, une exception DéjàQueued sera levée. Elle est très appropriée pour les tâches planifiées lorsque la tâche précédente n'a pas été exécutée, que le cycle suivant est arrivé et. services de tâches distribués. Scénarios mutuellement exclusifs.
https://pypi.python.org/pypi/...
Il existe une bibliothèque appelée celery_once. Le mécanisme derrière elle consiste à définir un verrouillage de tâche avec le nom de la tâche dans redis. Lorsqu'une tâche est en cours d'exécution, la même tâche ne peut pas être déclenchée à nouveau.
Lorsqu'une tâche est déclenchée, s'il s'avère que la tâche a déjà un verrou, une exception DéjàQueued sera levée. Elle est très appropriée pour les tâches planifiées lorsque la tâche précédente n'a pas été exécutée, que le cycle suivant est arrivé et. services de tâches distribués. Scénarios mutuellement exclusifs.
J'espère que cela vous sera utile.