Compensarea fluxurilor de lucru

Compensarea vă permite să atașați un gestionar de revenire la un pas finalizat al fluxului de lucru. Queuety stochează un instantaneu al stării publice la finalizarea pasului, apoi rulează gestionarii de compensare în ordine inversă când fluxul de lucru este anulat sau, opțional, când eșuează.

Metoda compensate_with()

Apelați compensate_with() imediat după pasul pe care trebuie să-l anuleze:

use Queuety\Queuety;

Queuety::workflow( 'provision_account' )
    ->then( CreateRemoteUserStep::class )
    ->compensate_with( DeleteRemoteUserCompensation::class )
    ->then( CreateSubscriptionStep::class )
    ->compensate_with( CancelSubscriptionCompensation::class )
    ->then( SendWelcomeEmailStep::class )
    ->dispatch( [ 'user_id' => 42 ] );

Dacă fluxul de lucru este anulat ulterior, Queuety rulează:

1. CancelSubscriptionCompensation
2. DeleteRemoteUserCompensation

Gestionari de compensare

Gestionarii de compensare implementează Contracts\Compensation:

use Queuety\Contracts\Compensation;

final class DeleteRemoteUserCompensation implements Compensation {
    public function handle( array $state ): void {
        remote_api_delete_user( $state['remote_user_id'] );
    }
}

Gestionarul primește starea publică a fluxului de lucru așa cum era imediat după finalizarea pasului compensat. Cheile interne rezervate nu sunt incluse.

Anulare sau eșec

La anularea explicită, compensările pașilor finalizați rulează întotdeauna înaintea gestionarului opțional on_cancel().

La eșec, compensările rulează numai dacă optați pentru aceasta:

Queuety::workflow( 'provision_account' )
    ->then( CreateRemoteUserStep::class )
    ->compensate_with( DeleteRemoteUserCompensation::class )
    ->then( CreateSubscriptionStep::class )
    ->compensate_with( CancelSubscriptionCompensation::class )
    ->then( ChargeCardStep::class )
    ->compensate_on_failure()
    ->dispatch( $payload );

Fără compensate_on_failure(), un flux de lucru eșuat își păstrează intact istoricul pașilor finalizați și poate fi reîncercat începând de la pasul eșuat.

Cu compensate_on_failure(), compensările pașilor finalizați rulează după ce fluxul de lucru este marcat ca eșuat. După aceea, retry_workflow() aruncă o excepție deoarece fluxul de lucru a fost deja compensat.

Tipuri de pași acceptate

Compensarea poate fi atașată la:

• pași secvențiali then()
• grupuri parallel()
• pași for_each()
• pași run_workflow()
• pași de întârziere delay()
• pași de semnal wait_for_signal()
• pași de dependență între fluxuri de lucru wait_for_workflow()

Pentru run_workflow() și for_each(), instantaneul pentru compensare este înregistrat după ce activitatea imbricată sau ramificată s-a încheiat complet.

on_cancel() sau compensare

Folosiți compensate_with() pentru a anula efectele secundare ale pașilor finalizați, în ordine inversă.

Folosiți on_cancel() pentru un singur cârlig de curățare la nivel de flux de lucru, care trebuie să ruleze ori de câte ori fluxul este anulat explicit.