Plantillas de flujos de trabajo

Ver como Markdown Editar en GitHub Documentación de 2cc7b2b

Las plantillas de flujos de trabajo permiten definir una vez la estructura de pasos de un flujo y ejecutarla varias veces por nombre. Resultan útiles cuando el mismo proceso de varios pasos debe ejecutarse con distintas cargas.

Definir una plantilla

Usa Queuety::define_workflow() para crear la plantilla y, después, regístrala:

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

Registra las plantillas pronto, por ejemplo, en el hook de inicialización de un plugin:

PHP

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

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

Ejecutar una plantilla

Ejecuta una plantilla registrada por su nombre con Queuety::run_workflow():

PHP

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

El segundo argumento es la carga o el estado inicial, igual que ->dispatch() en un constructor. El entero devuelto es el ID del flujo de trabajo.

Si la plantilla no está registrada, se lanza una RuntimeException.

Listar las plantillas registradas

Accede al registro de plantillas:

PHP

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

Ejemplo completo

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

Plantillas y flujos de trabajo integrados

	Flujo de trabajo integrado	Plantilla
Definición	Al ejecutarlo	Una vez, al registrarla
Ejecución	`Queuety::workflow('name')->then(...)->dispatch()`	`Queuety::run_workflow('name', $payload)`
Reutilización	Crear la cadena cada vez	Registrar una vez y ejecutar muchas
Ideal para	Flujos puntuales o compuestos dinámicamente	Procesos estándar y repetibles