Arbetsflödesmallar

Visa som Markdown Redigera på GitHub Dokumentation på 2cc7b2b

Med arbetsflödesmallar kan du definiera strukturen för ett arbetsflödes steg en gång och köra det flera gånger med namn. Det är användbart när samma process i flera steg behöver köras med olika nyttolaster.

Definiera en mall

Använd Queuety::define_workflow() för att bygga mallen och registrera den sedan:

PHP

use Queuety\Queuety;
use Queuety\Enums\Priority;

$builder = Queuety::define_workflow( 'onboarding' )
    ->on_queue( 'pipelines' )
    ->with_priority( Priority::Normal )
    ->max_attempts( 5 )
    ->then( CreateAccountHandler::class )
    ->then( SendWelcomeEmailHandler::class )
    ->then( NotifyAdminHandler::class );

Queuety::register_workflow_template( $builder );

Registrera mallar tidigt, till exempel i ett tilläggs initieringshook:

PHP

add_action( 'init', function () {
    $builder = Queuety::define_workflow( 'onboarding' )
        ->then( CreateAccountHandler::class )
        ->then( SendWelcomeEmailHandler::class )
        ->then( NotifyAdminHandler::class );

    Queuety::register_workflow_template( $builder );
} );

Köra en mall

Kör en registrerad mall med namn och Queuety::run_workflow():

PHP

$workflow_id = Queuety::run_workflow( 'onboarding', [ 'email' => 'user@example.com' ] );

Det andra argumentet är den initiala nyttolasten/det initiala tillståndet, precis som ->dispatch() i en byggare. Det returnerade heltalet är arbetsflödets ID.

Om mallen inte är registrerad kastas ett RuntimeException.

Lista registrerade mallar

Kom åt mallregistret:

PHP

$registry = Queuety::workflow_templates();
$template = $registry->get( 'onboarding' ); // WorkflowTemplate or null

Fullständigt exempel

PHP

// Register templates on init.
add_action( 'init', function () {
    // User onboarding pipeline
    $onboarding = Queuety::define_workflow( 'onboarding' )
        ->on_queue( 'users' )
        ->then( CreateAccountHandler::class )
        ->then( SetupDefaultsHandler::class )
        ->then( SendWelcomeEmailHandler::class );
    Queuety::register_workflow_template( $onboarding );

    // Content generation pipeline
    $content = Queuety::define_workflow( 'generate_content' )
        ->on_queue( 'llm' )
        ->max_attempts( 5 )
        ->then( BuildPromptHandler::class )
        ->then( CallLLMHandler::class )
        ->then( ReviewOutputHandler::class )
        ->then( PublishHandler::class );
    Queuety::register_workflow_template( $content );
} );

// Dispatch them anywhere in your application.
$wf1 = Queuety::run_workflow( 'onboarding', [ 'email' => 'alice@example.com' ] );
$wf2 = Queuety::run_workflow( 'generate_content', [ 'topic' => 'WordPress performance' ] );

Mallar jämfört med arbetsflöden direkt i koden

	Arbetsflöde direkt i koden	Mall
Definition	Vid körning	En gång, vid registrering
Körning	`Queuety::workflow('name')->then(...)->dispatch()`	`Queuety::run_workflow('name', $payload)`
Återanvändning	Bygg kedjan varje gång	Registrera en gång, kör många gånger
Bäst lämpad för	Engångsflöden eller dynamiskt sammansatta arbetsflöden	Standardiserade, upprepningsbara processer