スキーマ:

ACCOUNT_USAGE

TASK_VERSIONS ビュー

このAccount Usageビューにより、 タスクバージョン の履歴を取得できます。返された行は、特定の時点で DAG とそのプロパティを構成していたタスクを示します。

列名

データ型

説明

ROOT_TASK_ID

TEXT

DAG内のルートタスクの一意の識別子。この ID は、同じタスクの SHOW TASKS 出力にある ID 列の値と一致します。 COMPLETE_TASK_GRAPHSTASK_HISTORY の ROOT_TASK_ID に一致します。

GRAPH_VERSION

NUMBER

タスクのバージョンを識別する整数。 COMPLETE_TASK_GRAPHS の GRAPH_VERSION に一致します。

GRAPH_VERSION_CREATED_ON

TIMESTAMP_LTZ

このバージョンのタスクグラフが保存された日時。

NAME

TEXT

タスクの名前。

ID

TEXT

各タスクの一意の識別子。タスクを( CREATE OR REPLACE TASK を使用して)再作成すると、基本的に、新しい ID を持つ新しいタスクが作成されることに注意してください。

DATABASE_ID

NUMBER

タスクが含まれていたデータベースの内部/システム生成識別子。

DATABASE_NAME

TEXT

タスクが格納されているデータベースの名前。

SCHEMA_ID

NUMBER

タスクが含まれていたスキーマの内部/システム生成識別子。

SCHEMA_NAME

TEXT

タスクが格納されているスキーマの名前。

OWNER

TEXT

タスクを所有するロール(つまり、タスクに対する OWNERSHIP 権限を持つ)

COMMENT

TEXT

タスクのコメント。

WAREHOUSE_NAME

TEXT

タスクを実行するために必要なリソースを提供するウェアハウス。

SCHEDULE

TEXT

タスクを実行するスケジュール。スケジュールが指定されていない場合、 NULL を表示します。

PREDECESSORS

ARRAY

JSON タスクの AFTER パラメーターで識別されたタスク(つまり、先行タスク)の配列。正常に実行されて完了すると、これらのタスクが現在のタスクをトリガーします。配列内の個々のタスク名は完全修飾されています(つまり、コンテナーデータベースとスキーマ名が含まれます)。タスクに先行タスクがない場合は、空の配列が表示されます。

STATE

TEXT

タスクの現在の状態: started または suspended。 ルートタスク(先行タスクのないタスク)の場合は NULL

DEFINITION

TEXT

タスクの実行時に実行されるSQL ステートメント。

CONDITION_TEXT

TEXT

タスクの WHEN 句で指定された条件。

ALLOW_OVERLAPPING_EXECUTION

BOOLEAN

DAG 内のルートタスクの場合、 DAG の重複実行が明示的に許可されていると TRUE を表示します。DAG内の子タスクの場合、NULLを表示します。

ERROR_INTEGRATION

TEXT

Amazon Simple Notification Service(SNS)にアクセスしてタスクのエラー通知を中継するために使用される、通知統合の名前。

LAST_COMMITTED_ON

TIMESTAMP_LTZ

タスクのバージョンが最後に設定されたときのタイムスタンプ。バージョンが設定されていない場合(つまり、タスクが作成された後に再開されていないか、手動で実行されていない場合)、値は NULL です。

LAST_SUSPENDED_ON

TIMESTAMP_LTZ

タスクが最後に一時停止されたときのタイムスタンプ。タスクがまだ一時停止されていない場合、値は NULL です。

CONFIG

TEXT

ルートタスクに設定されている場合はグラフレベルの構成を表示します。それ以外の場合は NULL を表示します。

使用上の注意

ビューの待機時間は最大3時間です。

ROOT_TASK_ID と GRAPH_VERSION に基づいて、特定のタスク DAG からタスクを取得します。

SELECT *
FROM snowflake.account_usage.task_versions
WHERE ROOT_TASK_ID = 'afb36ccc-. . .-b746f3bf555d' AND GRAPH_VERSION = 3;
Copy

特定のタスク DAG とその子孫タスクのタスク実行をtask_historyから取得し、追加のタスク情報をtask_versionsから取得します。

SELECT
task_history.* rename state AS task_run_state,
task_versions.state AS task_state,
task_versions.graph_version_created_on,
task_versions.warehouse_name,
task_versions.comment,
task_versions.schedule,
task_versions.predecessors,
task_versions.allow_overlapping_execution,
task_versions.error_integration
FROM snowflake.account_usage.task_history
JOIN snowflake.account_usage.task_versions using (root_task_id, graph_version)
WHERE task_history.ROOT_TASK_ID = 'afb36ccc-. . .-b746f3bf555d'
Copy