Betinget forgrening

Vis som Markdown Rediger på GitHub Dokumentation hos 2cc7b2b

Arbejdsgange kan springe til et navngivet trin baseret på outputtet fra et tidligere trin. Det gøres ved at returnere en særlig nøgle _next_step i trinets returværdi.

Hvis du specifikt vil springe tilbage til et tidligere trin baseret på arbejdsgangens tilstand, kan du se Gentagelser. Så forbliver tilbagekanten eksplicit i arbejdsgangsdefinitionen i stedet for at være skjult i en trinklasse.

Navngivne trin

Giv trin et navn ved hjælp af det andet argument til ->then():

PHP

use Queuety\Queuety;

Queuety::workflow( 'process_order' )
    ->then( ValidateOrderHandler::class, 'validate' )
    ->then( ChargePaymentHandler::class, 'charge' )
    ->then( FulfillOrderHandler::class, 'fulfill' )
    ->then( SendConfirmationHandler::class, 'confirm' )
    ->then( HandleFailureHandler::class, 'failure' )
    ->dispatch( [ 'order_id' => 123 ] );

Uden et eksplicit navn får trin navn efter deres indeks ('0', '1', '2' osv.).

Nøglen `_next_step`

Et trin kan returnere _next_step for at springe til et navngivet trin og dermed springe alt imellem over. Trin efter springmålet køres stadig i rækkefølge: uden et spring fortsætter arbejdsgangen blot med næste trin på listen, så i eksemplet ovenfor fortsætter et vellykket trin confirm ind i failure, medmindre det returnerer en _next_step, der springer det over, eller HandleFailureHandler først kontrollerer, om der findes en nøgle error:

PHP

use Queuety\Step;

class ValidateOrderHandler implements Step {
    public function handle( array $state ): array {
        $order = wc_get_order( $state['order_id'] );

        if ( ! $order || $order->get_status() === 'cancelled' ) {
            return [
                'error'  => 'Order is invalid or cancelled',
                '_next_step'  => 'failure',
            ];
        }

        return [
            'order_total' => $order->get_total(),
            'customer_id' => $order->get_customer_id(),
        ];
    }

    public function config(): array {
        return [];
    }
}

Når ValidateOrderHandler returnerer _next_step => 'failure', springer arbejdsgangen over charge, fulfill og confirm og går direkte til trinnet failure. Nøglen _next_step forbruges af arbejdsgangsmotoren og gemmes ikke i tilstanden.

Forgreningsmønstre

Spring over ved betingelse

PHP

class CheckInventoryHandler implements Step {
    public function handle( array $state ): array {
        $in_stock = check_inventory( $state['sku'] );

        if ( ! $in_stock ) {
            return [
                'reason' => 'Out of stock',
                '_next_step'  => 'notify_backorder',
            ];
        }

        return [ 'inventory_reserved' => true ];
    }

    public function config(): array {
        return [];
    }
}

Afslut tidligt

Spring til det sidste trin for at undgå unødvendig behandling:

PHP

class CheckCacheHandler implements Step {
    public function handle( array $state ): array {
        $cached = get_transient( "report_{$state['user_id']}" );

        if ( $cached ) {
            return [
                'report_url' => $cached,
                '_next_step'      => 'done',
            ];
        }

        return [ 'cache_miss' => true ];
    }

    public function config(): array {
        return [];
    }
}

Fuldt eksempel

PHP

Queuety::workflow( 'content_pipeline' )
    ->then( CheckCacheHandler::class, 'check_cache' )
    ->then( FetchDataHandler::class, 'fetch' )
    ->then( CallLLMHandler::class, 'generate' )
    ->then( SaveResultHandler::class, 'save' )
    ->then( ReturnCachedHandler::class, 'done' )
    ->dispatch( [ 'user_id' => 42 ] );

Hvis cachekontrollen finder et hit, springer arbejdsgangen direkte fra check_cache til done og springer fetch, generate og save over. Ved et cache-miss køres trinene i rækkefølge, og save fortsætter også ind i done, så ReturnCachedHandler skal kunne håndtere begge forløb.