ワークフロー

ワークフローは、クラッシュや再起動を乗り越える耐久性のある長時間実行操作です。決済、注文処理、複数ステップの承認など、重要なビジネスプロセスに信頼性の保証を提供します。

なぜワークフローか？

関数は一時的なものです。ホストがクラッシュすると、進行中の作業は失われます。ワークフローは状態を永続化します：

ワークフローの動作

ワークフローのコードは通常のLuaコードのように見えます：

local funcs = require("funcs")
local time = require("time")

local result = funcs.call("app.api:charge_card", payment)
time.sleep("24h")
local status = funcs.call("app.api:check_status", result.id)

if status == "failed" then
    funcs.call("app.api:refund", result.id)
end

ワークフローエンジンは呼び出しをインターセプトし、結果を記録します。プロセスがクラッシュすると、履歴から実行がリプレイされます。同じコード、同じ結果です。

ワークフローパターン

Sagaパターン

失敗時に補償：

local funcs = require("funcs")

local inventory = funcs.call("app.inventory:reserve", items)
if inventory.error then
    return nil, inventory.error
end

local payment = funcs.call("app.payments:charge", amount)
if payment.error then
    funcs.call("app.inventory:release", inventory.id)
    return nil, payment.error
end

local shipping = funcs.call("app.shipping:create", order)
if shipping.error then
    funcs.call("app.payments:refund", payment.id)
    funcs.call("app.inventory:release", inventory.id)
    return nil, shipping.error
end

return {inventory = inventory, payment = payment, shipping = shipping}

シグナルの待機

外部イベント（承認決定、Webhook、ユーザーアクション）を待機：

local funcs = require("funcs")

funcs.call("app.approvals:submit", request)

local inbox = process.inbox()
local msg = inbox:receive()  -- シグナルが到着するまでブロック

if msg.approved then
    funcs.call("app.orders:fulfill", request.order_id)
else
    funcs.call("app.notifications:send_rejection", request)
end

いつ何を使うか

ワークフローの開始

ワークフローはプロセスと同じ方法で生成されます。process.spawn()を異なるホストで使用します：

-- temporal workerでワークフローを生成
local pid = process.spawn("app.workflows:order_processor", "app:temporal_worker", order_data)

-- ワークフローにシグナルを送信
process.send(pid, "update", {status = "approved"})

呼び出し元の観点からは、APIは同一です。違いはホストです：ワークフローはprocess.hostではなくtemporal.workerで実行されます。

障害とスーパービジョン

プロセスはprocess.serviceを使用して監督されたサービスとして実行できます：

# プロセス定義
- name: session_handler
  kind: process.lua
  source: file://session_handler.lua
  method: main

# プロセスをラップする監督されたサービス
- name: session_manager
  kind: process.service
  process: app:session_handler
  host: app:processes
  lifecycle:
    auto_start: true
    restart:
      max_attempts: 10

ワークフローはスーパービジョンツリーを使用しません。ワークフロープロバイダ（Temporal）によって自動的に管理されます。プロバイダは永続化、リトライ、リカバリを処理します。

設定

プロセス定義（動的に生成）：

- name: order_processor
  kind: workflow.lua
  source: file://order_processor.lua
  method: main
  modules:
    - funcs
    - time

ワークフロープロバイダ：

- name: temporal_worker
  kind: temporal.worker
  client: app:temporal_client
  task_queue: "orders"
  lifecycle:
    auto_start: true

本番ワークフローインフラストラクチャについてはTemporalを参照してください。

関連項目

• 関数 - ステートレスなリクエスト処理
• プロセスモデル - ステートフルなバックグラウンド作業
• スーパービジョン - プロセス再起動ポリシー