Wie verhindert man überlappende Jobs? DistributedMutex?

Entwickler
1

Plugin-Neuling hier. Ich versuche, ein Plugin anzupassen, das etwa eine Stunde in Anspruch nimmt. Wenn ich mir /sidekiq ansehe, stelle ich fest, dass der Job alle 30 Minuten ausgeführt wird. Bevor also der erste Job abgeschlossen ist, startet eine weitere Instanz desselben Jobs, was zu doppelten Ergebnissen führt. Wie kann ich das verhindern?

Eine Möglichkeit wäre natürlich, den Job innerhalb seiner erlaubten 30 Minuten ablaufen zu lassen, aber es gibt weitere Einschränkungen, und ich würde es lieber so lange laufen lassen, wie es möchte.

Ich habe Folgendes versucht, aber es scheint nicht zu verhindern, dass eine zweite Instanz des Jobs ausgeführt wird:

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

2

Ich glaube, dass der Zusammenfassungs-E-Mail-Job einen solchen Test durchführt, der Anfang dieses Jahres hinzugefügt wurde. Vielleicht solltest du dir das einmal ansehen.

3

Ich denke, ich mache dasselbe wie unter https://review.discourse.org/t/feature-allow-post-process-mutex-to-be-held-longer/5017 und https://review.discourse.org/t/fix-post-and-topic-creation-race-condition/5247, mit dem Unterschied, dass ich geschweifte Klammern anstelle von do/end verwende, aber das sollte keine Rolle spielen.

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

Dennoch wird do_stuff mehrfach gleichzeitig ausgeführt, und das auch noch innerhalb der 180 Minuten.

4

Wenn sich der Mutex innerhalb des execute-Blocks befindet, bedeutet das lediglich, dass er dort blockiert und auf den Mutex wartet. Das heißt, Sie werden zwei Jobs sehen: einen, der tatsächlich ausgeführt wird, und einen anderen, der auf den Mutex wartet.

Vielleicht möchten Sie prüfen, ob eine andere Instanz läuft, und im positiven Fall frühzeitig zurückkehren? Ohne genauere Kenntnis des konkreten Anwendungsfalls ist das schwer zu sagen.