Templat Alur Kerja

Lihat sebagai Markdown Edit di GitHub Dokumentasi di 2cc7b2b

Templat alur kerja memungkinkan Anda menentukan struktur langkah alur kerja sekali, lalu menjalankannya beberapa kali berdasarkan nama. Ini berguna ketika proses multi-langkah yang sama perlu dijalankan dengan payload yang berbeda.

Menentukan templat

Gunakan Queuety::define_workflow() untuk membuat templat, lalu daftarkan:

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

Daftarkan templat sejak awal, misalnya di hook inisialisasi 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 );
} );

Menjalankan templat

Jalankan templat yang terdaftar berdasarkan nama dengan Queuety::run_workflow():

PHP

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

Argumen kedua adalah payload/status awal, seperti ->dispatch() pada builder. Bilangan bulat yang dikembalikan adalah ID alur kerja.

Jika templat belum terdaftar, RuntimeException akan dilempar.

Melihat daftar templat terdaftar

Akses registri templat:

PHP

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

Contoh lengkap

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

Templat dan alur kerja inline

	Alur kerja inline	Templat
Definisi	Saat dijalankan	Sekali, saat pendaftaran
Menjalankan	`Queuety::workflow('name')->then(...)->dispatch()`	`Queuety::run_workflow('name', $payload)`
Penggunaan ulang	Bangun rangkaian setiap kali	Daftarkan sekali, jalankan berkali-kali
Cocok untuk	Alur kerja sekali pakai atau yang disusun secara dinamis	Proses standar yang dapat diulang