フェイズとタスク

rehearsalにおけるフェイズによるタスクの強制的な分割について解説します。

1 minute read

タスク間の依存関係

ドキュメント「プロセスとタスク」でも解説した通り、rehearsalのタスクは並列的に実行されます。これは各タスクの入出力をリアルタイムに同期させる意味では理想的な状態です。しかし、現実では以下のような不都合を生じることがあります。

他のタスクに依存する場合
- これには、アプリケーションのビルドをタスクに含める場合などが含まれます。
一度にデータを送信したい場合
- rehearsalのように非同期の仕組みを持たないレガシーなプロダクトを使用する場合などが含まれます。

rehearsalではそのようなニーズに対応するため、フェイズという概念を導入することで、排他的なタスクの実行を行うことができます。

といっても、フェイズは口にするほど難しい概念ではありません。同一フェイズに含まれるタスクを並列的に実行し、そのフェイズ内のタスクが終了するまで他のフェイズ内に含まれてるタスクの実行を待機する仕組みです。

以下の例を見てください。以下の例ではphase1とphase2という名前のフェイズをそれぞれ定義し、その中でそれぞれにtaskという名前のタスクを定義しています。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10


version: 1.202109
phase:
- name: phase1
  task:
  - name: task # (1)
  　wait: true
- name: phase2
  task:
  - name: task # (2)
    wait: true

(1)と(2)は同一名ですがrehearsal内部では別名として定義され、それぞれphase1::taskとphase2::taskとして定義されます。これらの命名はsendtoプロパティで送信先のタスクを指定する際に使用できます。

この例では以下のような実行フローとなります。

flowchart TB
  Begins[rehearsal実行開始]
  Ends[rehearsal実行終了]
  Task1Begins[タスク1実行開始] .-> Task1Waits[タスク1終了待機] .-> Task1Ends[タスク1実行終了]
  Task2Begins[タスク2実行開始] .-> Task2Waits[タスク2終了待機] .-> Task2Ends[タスク2実行終了]
  subgraph Phase1[ ]
    direction LR
    subgraph Phase1Begins[Phase1実行開始]
      Task1Begins
    end
    subgraph Phase1Ends[Phase1終了待機/実行終了]
      Task1Waits
      Task1Ends
    end
    Phase1Begins --> Phase1Ends
  end
  subgraph Phase2[ ]
    direction LR
    subgraph Phase2Begins[Phase2実行開始]
      Task2Begins
    end
    subgraph Phase2Ends[Phase2終了待機/実行終了]
      Task2Waits
      Task2Ends
    end
    Phase2Begins --> Phase2Ends
  end
  Begins --> Phase1 --> Phase2 --> Ends

フェイズ間の越境とタスク

前のセクションではタスクの実行を分割する方法について説明しました。しかし、現実では複数のフェイズ間で単一のタスクを実行したい場合があります。そういった場合にuntilプロパティは有用です。

このプロパティは別のフェイズで終了待機または実行終了を行うことを指定します。指定しなかった場合は実行したフェイズで終了待機または実行終了を行います。

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16


version: 1.202109
phase:
- name: phase1
  task:
  - name: task1 # (1)
  　wait: true
  - name: task2 # (2)
    wait: true
    until: phase2
  - name: task3 # (3)
    wait: true
    until: __eternal
- name: phase2
  task:
  - name: task4 # (4)
    wait: true

flowchart LR
  Begins[rehearsal実行開始]
  Ends[rehearsal実行終了]
  Begins --> Phase1 --> Phase2 --> Finalize --> Ends
  Task1Begins[タスク1実行開始] .-> Task1Waits[タスク1終了待機] .-> Task1Ends[タスク1実行終了]
  Task2Begins[タスク2実行開始] .-> Task2Waits[タスク2終了待機] .-> Task2Ends[タスク2実行終了]
  Task3Begins[タスク3実行開始] .-> Task3Waits[タスク3終了待機] .-> Task3Ends[タスク3実行終了]
  Task4Begins[タスク4実行開始] .-> Task4Waits[タスク4終了待機] .-> Task4Ends[タスク4実行終了]
  subgraph Phase1[ ]
    direction TB
    subgraph Phase1Begins[Phase1実行開始]
      Task1Begins
      Task2Begins
      Task3Begins
    end
    subgraph Phase1Ends[Phase1終了待機/実行終了]
      Task1Waits
      Task1Ends
    end
    Phase1Begins --> Phase1Ends
  end
  subgraph Phase2[ ]
    direction LR
    subgraph Phase2Begins[Phase2実行開始]
      Task4Begins
    end
    subgraph Phase2Ends[Phase2終了待機/実行終了]
      Task2Waits
      Task2Ends
      Task4Waits
      Task4Ends
    end
    Phase2Begins --> Phase2Ends
  end
  subgraph Finalize[__eternalフェイズ]
    Task3Waits
    Task3Ends
  end

(1)のタスクは前のセクションと同じ、同一のフェイズ内で実行および終了待機を行っています。それに比べて(2)のタスクはPhase1フェイズで実行開始した後、untilプロパティで指定したPhase2フェイズにて終了待機を行います。

(3)のタスクのuntilプロパティには__eternalが定義されています。これは一番最後に終了するタスクを定義するためのシステム内で定義されるフェイズです。これはユーザーの定義したすべてのフェイズが終了した後に実行されることが保証されます。