- Farklı sürelerde çalışan işçiler
- Sürümü belirli ortak kontrol noktası
- Birleştir veya gecikmeyi açıkça bildir
Kontrol noktalarını tanımla
Hangi görevlerin birlikte okunması gerektiğini yaz. Her checkpoint için zorunlu ve isteğe bağlı girdileri ayır.
Olayla ilerle
İşçi tamamlandığında event_id, task_id, checkpoint_version ve artefakt referansı yayınlar. Tekrarlanan olayı tekilleştir.
Gecikmeyi sınırla
Zaman aşımında eksik girdiyi açıkça raporla. Eksik zorunlu girdiyle tamamlanmış sonuç etiketi üretme.
Sürümü birleştir
Aynı sürüme ait çıktıları tekleştir; geç geleni sonraki incelemeye al. Deney sonunda bekleme maliyetini kaydet.
Rollerin sorumluluğu
- Asenkron işçi
- Çıktısını olay kimliği ve sürümle üretir; kontrol noktasını beklerken işi kaybetmez.
- Birleştirici
- Aynı kontrol noktası sürümündeki hazır çıktıları birleştirir.
- Gecikme denetçisi
- Eksik görev, yeniden deneme ve zaman aşımını kaydeder.
Ortak hafıza sözleşmesi
event_idtask_idcheckpoint_versionartifact_refreceived_atrequiredtimeout_result- Durma koşulu
- Zorunlu girdiler doğrulanıp birleştirildiyse bitir. Süre dolmuş ve eksik girdi varsa tamamlanmamış durumla teslim et.
- Başlıca hata biçimi
- Sürümleri karıştırmak yanlış sentez; küresel bariyer ise tek yavaş işçiye bağımlılık yaratır. Tekrar mesajları idempotent işle.