スキーマ:

ORGANIZATION_USAGE

COMPLETE_TASK_GRAPHS ビュー

重要

この表示は組織アカウントでのみ利用可能です。詳細については、 組織アカウントのプレミアムビュー をご参照ください。

Organization Usageビューを使用して、完了した グラフ の実行ステータス(成功した実行、失敗した実行、キャンセルされた実行など)をクエリできます。グラフは現在、単一のスケジュールされたタスク、 または スケジュールされたルートタスクと1つ以上の子タスクで構成される タスクグラフ として定義されています。この関数では、 ルートタスク は、スケジュールされた単一のタスクか、タスクグラフのルートタスクのどちらかを指します。

ビューは、 COMPLETE_TASK_GRAPHS の10万行の制限を回避します。

組織レベルの列

列名

データ型

説明

ORGANIZATION_NAME

VARCHAR

組織の名前。

ACCOUNT_LOCATOR

VARCHAR

システムが生成したアカウントの識別子。

ACCOUNT_NAME

VARCHAR

ユーザー定義のアカウント識別子。

追加列

列名

データ型

説明

ROOT_TASK_NAME

TEXT

ルートタスクの名前。

DATABASE_NAME

TEXT

グラフを含むデータベースの名前。

SCHEMA_NAME

TEXT

グラフを含むスキーマの名前。

STATE

TEXT

グラフ実行の状態。

  • SUCCEEDED: グラフ内のすべてのタスクが正常に実行されて完了するか、ルートタスク実行に成功し、1つ以上の子タスク実行がスキップされました。

  • FAILED: グラフ内の1つ以上のタスク実行に失敗したか、ルートタスク実行に成功し、1つ以上の子タスク実行に失敗しました。

  • CANCELLED: グラフ内の1つ以上のタスク実行がキャンセルされたか、ルートタスク実行に成功し、1つ以上の子タスク実行がキャンセルされました。

ルートタスク実行の状態が SKIPPED の場合、関数は実行の行を返さないことに注意してください。

SCHEDULED_FROM

TEXT

次のいずれか:

  • SCHEDULE: CREATE TASK の SCHEDULE 句または AFTER 句で説明されているように、タスクは正常に実行されるようにスケジュールされました。

  • EXECUTE TASK: タスクは EXECUTE TASK を使用して実行するようにスケジュールされました。

  • MANUAL RETRY: タスクは EXECUTE TASK ... RETRY LAST を使用して実行するようにスケジュールされました。

  • TRIGGER: タスクの WHEN 句のストリームに新しいデータが含まれていたため、タスクが実行されました。

タスクグラフにある子タスクの実行の場合、列はルートタスクの実行と同じ値を返します。

FIRST_ERROR_TASK_NAME

TEXT

エラーを返したグラフにある最初のタスクの名前。エラーが発生したタスクがない場合は、 NULL を返します。

FIRST_ERROR_CODE

NUMBER

FIRST_ERROR_TASK_NAME で名前を付けられたタスクによって返されるエラーのエラーコード。エラーが発生したタスクがない場合は NULL を返します。

FIRST_ERROR_MESSAGE

TEXT

FIRST_ERROR_TASK_NAME で名前を付けられたタスクによって返されるエラーのエラーメッセージ。エラーが発生したタスクがない場合は NULL を返します。

SCHEDULED_TIME

TIMESTAMP_LTZ

ルートタスクが実行を開始するようにスケジュールされた時刻。絶対精度を確保するために最善を尽くしますが、保証は、スケジュールされた時間の にタスクが実行されないようにすることのみに限定されます。

QUERY_START_TIME

TIMESTAMP_LTZ

ルートタスク定義のクエリの実行が開始された時刻。このタイムスタンプは、 QUERY_HISTORY によって返されるクエリの開始時間と一致します。

NEXT_SCHEDULED_TIME

TIMESTAMP_LTZ

SCHEDULED_TIME 時に開始されたスタンドアロンタスクまたは DAG の現在の実行が時間内に完了すると仮定して、スタンドアロンタスクまたはルートタスク(タスクの DAG 内)が次に実行を開始するようにスケジュールされる時刻。

COMPLETED_TIME

TIMESTAMP_LTZ

DAG 内の最後のタスクが完了した時刻。

ROOT_TASK_ID

TEXT

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

GRAPH_VERSION

NUMBER

実行された、または実行予定の DAG のバージョンを識別する整数。

RUN_ID

NUMBER

DAG 内のスタンドアロンタスクまたはルートタスクが本来実行を開始するようにスケジュールされている、またはされていた時刻。形式はエポック時間(単位:ミリ秒)です。 . . 元の スケジュール時間とは、システムが同じタスクを再スケジュールして異なる時間に実行し、再試行またはロードのリバランスを行うまれなインスタンスを指します。その場合、RUN_IDは元のスケジュールされた実行時間を表示し、SCHEDULED_TIMEは再スケジュールされた実行時間を表示します。 . . RUN_ID は、再試行前に実行された現在のタスク/グラフの一意な識別子ではない可能性があります。RUN_ID の代わりとして、 GRAPH_RUN_GROUP_ID 列を使用することができます。

ATTEMPT_NUMBER

NUMBER

このタスクの実行を試行した回数を表す整数。初期値は1。

CONFIG

TEXT

明示的に設定されている場合は、グラフの実行中に使用されたグラフレベルの構成を表示します。それ以外の場合は NULL を表示します。

GRAPH_RUN_GROUP_ID

NUMBER

グラフ実行の識別子。グラフ実行に複数のタスク実行がある場合、各タスク実行は同じ GRAPH_RUN_GROUP_ID を表示します。GRAPH_RUN_GROUP_ID、および ATTEMPT_NUMBER の組み合わせは、グラフの実行を一意に識別するために使用できます。

BACKFILL_INFO

OBJECT

今後の使用のために予約されています。すべての行に対して返される値は NULL です。

使用上の注意

  • ビューの遅延は最大24時間です。

  • ビューには、セッションの現在のロールにアクセス権が付与されているオブジェクトのみが表示されます。

組織で完了した最新のタスクグラフ実行のうち、直近10件の記録を取得します。

SELECT account_name, root_task_name, state
FROM snowflake.organization_usage.complete_task_graphs
  LIMIT 10;
Copy