ワークフローのフォーク

Queuetyを使うと、実行中のワークフローを完全に独立したコピーにフォークできます。フォークされたワークフローは、元のワークフローと同じステップ、同じ状態で開始しますが、その後は互いに独立して進行します。一方への変更は、もう一方に影響しません。

ワークフローのフォーク

PHP API

ワークフローIDを指定してQueuety::fork_workflow()を呼び出します。新しいワークフローIDが返されます。

use Queuety\Queuety;

$forked_id = Queuety::fork_workflow( $workflow_id );

CLI

wp queuety workflow fork <id>

wp queuety workflow fork 42
# Success: Workflow #42 forked. New workflow ID: 43.

仕組み

ワークフローをフォークすると、次の処理が行われます。

1. 元のワークフローの行がロックされ、読み取られる
2. 同じ状態、ステップ定義、現在のステップを持つ新しいワークフロー行が挿入される
3. 新しいワークフローの名前は{original_name}_fork_{timestamp}になる
4. フォークしたワークフローの現在のステップがキューに追加される
5. 元のワークフローとフォークしたワークフローの両方にworkflow_forkedログイベントが記録される
6. 元のワークフローは通常どおり処理を続ける

フォークしたワークフローは完全に独立しています。独自のワークフローID、状態のコピー、ジョブキュー項目を持ちます。フォークした時点以降は、各ワークフローは自由に異なる経路を進めます。

活用例

ステップハンドラーのA/Bテスト

今後のステップに対する2つの異なる実装をテストするには、ワークフローをフォークします。

// Original workflow will use the existing CallLLMHandler (GPT-4).
// Fork it to test with a different handler.
$forked_id = Queuety::fork_workflow( $workflow_id );

// Modify the forked workflow's state to use a different model.
// (Update the state via a custom step or direct DB update.)

仮説分析

判断点でワークフローをフォークし、異なるブランチを試します。

// Workflow is at step 3, about to process data.
// Fork it so we can try two different processing strategies.
$fork_a = Queuety::fork_workflow( $workflow_id );
$fork_b = Queuety::fork_workflow( $workflow_id );

各フォークは同じ入力状態から進みますが、異なる経路をたどるように変更できます。

並行実験

ワークフローで複数の方法を並行して試したい場合は、それぞれの方法ごとにフォークし、すべてのフォークが完了した後で結果を比較します。

フォークの追跡

各ワークフローのログイベントには、もう一方への参照が含まれます。

• 元のワークフローでは、context.forked_workflow_idが新しいワークフローを指します
• フォークでは、context.forked_from_workflow_idが元のワークフローを指します

ログを検索して、あるワークフローから作成されたすべてのフォークを見つけます。

$logs = Queuety::logger()->for_workflow( $workflow_id );

foreach ( $logs as $entry ) {
    if ( 'workflow_forked' === $entry['event'] ) {
        $context = json_decode( $entry['context'] ?? '{}', true );
        // $context['forked_workflow_id'] is the new workflow
    }
}

制限事項

• フォークしたワークフローは、元のワークフローのイベントログ履歴を引き継ぎません。空のイベントログで開始します。
• ワークフロー実行の関連付けは複製されません。元のワークフローで実行中のワークフロー実行があっても、フォークにはコピーされません。
• フォークは現在の状態のスナップショットです。元のワークフローで進行中のジョブは複製されません。