EXECUTE TASK¶

タスクに定義されたスケジュールとは関係なく、スケジュールされたタスク（スタンドアロンタスクまたはタスクの DAG （有向非巡回グラフ）のルートタスク）の非同期の単一実行を手動でトリガーします。

先行タスクが完了するにつれて、ルートタスクが正常に実行されると、ルートタスクが定義されたスケジュールで実行されたかのように、DAG内にある子タスクのカスケード実行がトリガーされます。

さらに、以前に失敗したタスクの再実行を手動でトリガーすることもできます。

こちらもご参照ください。: CREATE TASK 、 DROP TASK 、 SHOW TASKS

構文¶

EXECUTE TASK <name>

EXECUTE TASK <name> RETRY LAST

Copy

パラメーター¶

name

実行するスタンドアロンタスクまたはルートタスクの識別子。識別子にスペースまたは特殊文字が含まれる場合は、文字列全体を二重引用符で囲む必要があります。二重引用符で囲まれた識別子も大文字と小文字が区別されます。

RETRY LAST

失敗した name のタスクのDAG の最終タスクを失敗したタスクから再実行します。

タスクを再実行するには、以下の条件を満たす必要があります。

最後の DAG 実行は状態が FAILED か CANCELED であること。
DAG が最後に実行されてから変更されていないこと。
DAG は過去14日以内に実行または再試行されていること。

タスク履歴を表示するには、 TASK_HISTORY テーブル関数または Snowsightタスク履歴をご参照ください。

注釈

RETRY LAST は、最後に失敗したタスクから実行を開始する新しいグラフ実行を作成します。

具体的には、 FAILED または CANCELED タスクの実行はすべて直ちに再実行され、関連する子タスクは、それらの先行タスクがすべて正常に実行された場合にスケジュールされます。

さらに、再試行によって生成される新しい DAG 実行は、前回失敗したグラフ実行よりも1つ大きい ATTEMPT NUMBER を持ち、再試行された、つまり元の DAG 実行と同じ GRAPH_RUN_GROUP_ID を共有します。

使用上の注意¶

タスクを実行するには、タスクの OWNERSHIP または OPERATE 権限が必要です。

EXECUTE TASK コマンドがタスク実行をトリガーすると、Snowflakeは、タスクに対する OWNERSHIP 権限を持つロールが、タスクに割り当てられたウェアハウスに対する USAGE 権限、およびグローバル EXECUTE TASK 権限を持っていることを確認します。それ以外の場合は、エラーが生成されます。

OPERATE 権限を持つ別のロールが EXECUTE TASK を使用してタスクを実行する場合でも、タスクは常に元の所有者ロールの権限で実行されます。
SQLコマンドは、スタンドアロンタスクまたはDAG内のルートタスクのみを実行できます。子タスクが入力された場合、コマンドはユーザーエラーを返します。
スタンドアロンまたはルートタスクを手動で実行すると、タスクのバージョンが確立されます。スタンドアロンタスクまたはDAG全体が、このバージョンで実行を完了します。タスクバージョンの詳細については、実行のバージョニングをご参照ください。
一時停止されたルートタスクは、タスクを再開することなく実行されます。この SQL コマンドを実行する前に、ルートタスクを明示的に再開する必要はありません。ただし、EXECUTE TASKは、DAG内の子タスクを自動的に再開しません。このコマンドは、一時停止されている子タスクをスキップします。

DAGでルートタスクに関連付けられたすべての依存タスクを再帰的に再開するには、各タスクを個別に有効にするのではなく、 SYSTEM$TASK_DEPENDENTS_ENABLE 関数をクエリします（ALTER TASK ... RESUMEを使用）。

新規または変更されたDAGsをテストする際のベストプラクティスとして、ルートタスクを目的の運用スケジュールで実行するように設定しますが、一時停止状態のままにします。DAGのテストに成功した後、ルートタスクを再開します。テストのために、DAG内で一時停止された子タスクを再開する必要があることに注意してください。そうしないと、DAGの実行中にスキップされます。
ルートタスクが現在実行中の場合（つまり、 TASK_HISTORY 出力で EXECUTING 状態）、 EXECUTE TASK コマンドは、現在の実行が完了した直後にタスクの別の実行を開始するようにスケジュールします。
ルートタスクが現在スケジュールされている場合（つまり、 TASK_HISTORY 出力の SCHEDULED 状態）、スケジュールされた実行は、現在のタイムスタンプをスケジュールされた時刻として、通常どおりリクエストされた実行に置き換えられます。ただし、スケジュールされた時間が経過した場合（ただし、タスクがまだ EXECUTING 状態に移行していない場合）、スケジュールされた実行は通常どおりに実行されます。つまり、スケジュールされた実行は、リクエストされた実行に置き換えられません。

ルートタスクに設定されたALLOW_OVERLAPPING_EXECUTIONパラメーターは、DAGの重複するインスタンスを許可するかどうかを決定します。リクエストされたタスク実行の動作は、パラメーター値によって異なります。

ALLOW_OVERLAPPING_EXECUTION = FALSE （デフォルト値）	DAGのインスタンスが現在実行されていない場合、EXECUTE TASKコマンドは、DAGの別の実行をすぐに開始するようにスケジュールします。 DAG内のルートタスクまたは子タスクが現在実行中の場合（つまり、 TASK_HISTORY 出力でEXECUTING状態）、EXECUTE TASKコマンドは、 DAG内にある最終タスクの現在の実行が完了次第ただちに、DAGの別の実行が開始するようにスケジュールします。つまり、タスクDAGの現在のインスタンスは、リクエストされたタスクの開始前に実行を完了する必要があります。ルートタスクが現在スケジュールされている場合（つまり、 TASK_HISTORY 出力の SCHEDULED 状態）、スケジュールされた実行は、現在のタイムスタンプをスケジュールされた時刻として、リクエストされた実行に置き換えられます。ただし、スケジュールされた時間が経過した場合（しかし、タスクはまだ EXECUTING 状態に移行していない場合）、スケジュールされた実行が発生します。つまり、スケジュールされた実行は、リクエストされた実行に置き換えられません。
ALLOW_OVERLAPPING_EXECUTION = TRUE	DAGのインスタンスが現在実行されていない場合、またはDAG内の子タスクのみがインスタンスで実行されている場合、EXECUTE TASKコマンドは、DAGの別の実行をすぐに開始するようにスケジュールします。ルートタスクが現在DAGのインスタンスで実行されている場合、EXECUTE TASK コマンドは、ルートタスクの現在の実行が完了した直後に開始するように、DAGの別の実行をスケジュールします。ルートタスクが、DAGのインスタンス内で現在スケジュールされている場合（つまり、 TASK_HISTORY 出力の SCHEDULED状態）、スケジュールされた実行は、現在のタイムスタンプをスケジュールされた時刻として、通常どおりリクエストされた実行に置き換えられます。ただし、スケジュールされた時間が経過した場合（しかし、タスクはまだ EXECUTING 状態に移行していない場合）、スケジュールされた実行が発生します。つまり、スケジュールされた実行は、リクエストされた実行に置き換えられません。

ALLOW_OVERLAPPING_EXECUTION = FALSE （デフォルト値）

DAGのインスタンスが現在実行されていない場合、EXECUTE TASKコマンドは、DAGの別の実行をすぐに開始するようにスケジュールします。

DAG内のルートタスクまたは子タスクが現在実行中の場合（つまり、 TASK_HISTORY 出力でEXECUTING状態）、EXECUTE TASKコマンドは、 DAG内にある最終タスクの現在の実行が完了次第ただちに、DAGの別の実行が開始するようにスケジュールします。つまり、タスクDAGの現在のインスタンスは、リクエストされたタスクの開始前に実行を完了する必要があります。

ルートタスクが現在スケジュールされている場合（つまり、 TASK_HISTORY 出力の SCHEDULED 状態）、スケジュールされた実行は、現在のタイムスタンプをスケジュールされた時刻として、リクエストされた実行に置き換えられます。ただし、スケジュールされた時間が経過した場合（しかし、タスクはまだ EXECUTING 状態に移行していない場合）、スケジュールされた実行が発生します。つまり、スケジュールされた実行は、リクエストされた実行に置き換えられません。

ALLOW_OVERLAPPING_EXECUTION = TRUE

DAGのインスタンスが現在実行されていない場合、またはDAG内の子タスクのみがインスタンスで実行されている場合、EXECUTE TASKコマンドは、DAGの別の実行をすぐに開始するようにスケジュールします。

ルートタスクが現在DAGのインスタンスで実行されている場合、EXECUTE TASK コマンドは、ルートタスクの現在の実行が完了した直後に開始するように、DAGの別の実行をスケジュールします。

ルートタスクが、DAGのインスタンス内で現在スケジュールされている場合（つまり、 TASK_HISTORY 出力の SCHEDULED状態）、スケジュールされた実行は、現在のタイムスタンプをスケジュールされた時刻として、通常どおりリクエストされた実行に置き換えられます。ただし、スケジュールされた時間が経過した場合（しかし、タスクはまだ EXECUTING 状態に移行していない場合）、スケジュールされた実行が発生します。つまり、スケジュールされた実行は、リクエストされた実行に置き換えられません。

EXECUTE TASK コマンドの呼び出しは同期的に処理されますが、タスク実行は非同期操作です。
この SQL コマンドによってトリガーされるタスク実行では、コマンドの実行時に最新であったタスクバージョンが使用されます。タスクが、コマンドの実行後で、実行が開始される前に変更される場合、変更は、次のスケジュールされた実行まで適用されません。

タスクの実行中にこの SQL コマンドが複数回実行された場合、最後のコマンドを除くすべてのコマンドの実行は無視されます。次の実行が開始されると、最後の実行が行われたときに最新であったタスクバージョンが使用されます。
タスクが予期しないエラーで失敗した場合、エラーに関する通知を受け取ることができます。タスクエラー通知の構成の詳細については、タスクのエラー通知の有効化をご参照ください。
タスク情報を表示するには、以下のいずれかを実行します。
- Snowsight を開き、 Activity » Task History を選択します。
- COMPLETE_TASK_GRAPHS テーブル関数を呼び出し、結果を調べます。

例¶

mytask という名前のタスクの実行を手動でトリガーします。

EXECUTE TASK mytask;

Copy