Darbplūsmas kompensācija

Kompensācija ļauj pabeigtai darbplūsmas darbībai pievienot atcelšanas apstrādātāju. Queuety saglabā publiskā stāvokļa momentuzņēmumu, kad darbība ir pabeigta, un pēc tam apgrieztā secībā palaiž kompensācijas apstrādātājus, kad darbplūsma tiek atcelta vai, pēc izvēles, kad tā beidzas ar kļūdu.

Metode compensate_with()

Izsauciet compensate_with() uzreiz pēc darbības, kuru tai jāatceļ:

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 ] );

Ja darbplūsma vēlāk tiek atcelta, tiek palaista Queuety:

1. CancelSubscriptionCompensation
2. DeleteRemoteUserCompensation

Kompensācijas apstrādātāji

Kompensācijas apstrādātāji implementē 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'] );
    }
}

Apstrādātājs saņem publisko darbplūsmas stāvokli tādu, kāds tas bija uzreiz pēc kompensētās darbības pabeigšanas. Rezervētās iekšējās atslēgas nav iekļautas.

Atcelšana un kļūme

Skaidras atcelšanas gadījumā pabeigto darbību kompensācijas vienmēr tiek izpildītas pirms izvēles on_cancel() apstrādātāja.

Kļūmes gadījumā kompensācijas tiek izpildītas tikai tad, ja to izvēlaties:

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 );

Bez compensate_on_failure() darbplūsma ar kļūdu saglabā pabeigto darbību vēsturi, un to var atkārtot no darbības, kurā radās kļūda.

Ar compensate_on_failure() pabeigto darbību kompensācijas tiek izpildītas pēc tam, kad darbplūsma atzīmēta kā neveiksmīga. Pēc tam retry_workflow() izmet kļūdu, jo darbplūsmai jau ir veikta kompensācija.

Atbalstītie darbību veidi

Kompensāciju var pievienot šādiem elementiem:

• secīgām then() darbībām
• parallel() grupām
• for_each() darbībām
• run_workflow() darbībām
• delay() aiztures darbībām
• wait_for_signal() signāla darbībām
• wait_for_workflow() darbplūsmas atkarības darbībām

Attiecībā uz run_workflow() un for_each() kompensācijas momentuzņēmums tiek ierakstīts pēc tam, kad ligzdotais vai sazarotais darbs ir pilnībā pabeigts.

on_cancel() un kompensācija

Izmantojiet compensate_with(), lai apgrieztā secībā atceltu pabeigto darbību blakusefektus.

Izmantojiet on_cancel() vienam darbplūsmas līmeņa tīrīšanas āķim, kas jāpalaiž ikreiz, kad darbplūsma tiek skaidri atcelta.