¿Cómo evitar trabajos superpuestos? ¿DistributedMutex?

Desarrollador
1

Soy nuevo en los plugins. Estoy intentando adaptar un plugin que tarda aproximadamente una hora en ejecutarse. Al revisar /sidekiq, veo que el trabajo se ejecuta cada 30 minutos. Así que, antes de que termine el primer trabajo, se inicia otra instancia del mismo trabajo, creando resultados duplicados. ¿Cómo puedo evitar esto?

Una opción, por supuesto, es hacer que el trabajo se ejecute dentro de sus 30 minutos permitidos, pero hay otras restricciones y preferiría dejar que se ejecute el tiempo que necesite.

Probé esto, pero parece que no evita que se ejecute una segunda instancia del trabajo:

DistributedMutex.synchronize("custom_digest", validity: 180.minutes)

2

Creo que el trabajo del correo electrónico de resumen realiza esa prueba que se añadió a principios de este año. Podrías echar un vistazo a eso.

3

Creo que estoy haciendo lo mismo que en https://review.discourse.org/t/feature-allow-post-process-mutex-to-be-held-longer/5017 y https://review.discourse.org/t/fix-post-and-topic-creation-race-condition/5247, con la excepción de usar llaves en lugar de do/end, pero no creo que eso importe.

DistributedMutex.synchronize(“custom_digest”, validity: 180.minutes) {
do_stuff
}

Sin embargo, do_stuff se está ejecutando varias veces de forma concurrente, y muy dentro de los 180 minutos.

4

Si el mutex está dentro del bloque execute, simplemente significa que se bloqueará allí esperándolo, lo que significa que verás dos trabajos ejecutándose: uno realmente en ejecución y otro esperando el mutex.

¿Quizás quieras verificarlo y retornar temprano si hay otra instancia en ejecución? Es difícil adivinar con tan poco conocimiento sobre el caso de uso exacto.