COMPLETE_TASK_GRAPHS 视图¶
重要
此视图仅在组织账户中可用。有关更多信息,请参阅 组织账户中的高级视图。
您可以使用 Organization Usage 视图查询已完成的 图表 运行的状态,例如成功执行、失败或取消的运行。图形目前被定义为单个计划任务 或 一个由计划的根任务和一个或多个子任务组成的 任务图。就此函数而言,根任务 是指单个计划任务或任务图中的根任务。
该视图避免了 COMPLETE_TASK_GRAPHS 的 10,000 行限制。
列¶
列名称 |
数据类型 |
描述 |
---|---|---|
ORGANIZATION_NAME |
VARCHAR |
组织的名称。 |
ACCOUNT_LOCATOR |
VARCHAR |
系统定义的账户标识符。 |
ACCOUNT_NAME |
VARCHAR |
用户定义的账户标识符。 |
ROOT_TASK_NAME |
TEXT |
根任务的名称。 |
DATABASE_NAME |
TEXT |
包含图形的数据库的名称。 |
GRAPH_DATABASE_ID |
NUMBER |
|
SCHEMA_NAME |
TEXT |
包含图形的架构的名称。 |
GRAPH_SCHEMA_ID |
NUMBER |
|
STATE |
TEXT |
图形运行状态:
请注意,如果根任务运行的状态为 SKIPPED,则该函数不会返回运行的行。 |
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 |
独立任务或根任务(在任务的 DAG 中)下次计划开始运行的时间,假设在 SCHEDULED_TIME 时间开始的独立任务或 DAG 的当前运行及时完成。 |
COMPLETED_TIME |
TIMESTAMP_LTZ |
DAG 中最后一个任务完成的时间。 |
ROOT_TASK_ID |
TEXT |
DAG 中根任务的唯一标识符。此 ID 与同一任务的 ID SHOW 输出中的 TASKS 列值匹配。 |
GRAPH_VERSION |
NUMBER |
整数,用于识别已运行或计划运行的 DAG 版本。 |
RUN_ID |
NUMBER |
DAG 中的独立任务或根任务最初计划开始运行的时间。格式是纪元时间(以毫秒为单位)。. . 最初 计划时间是指系统可能会将同一任务重新计划为在不同时间运行以重试或重新平衡负载的罕见情况。如果发生这种情况,RUN_ID 会显示最初计划运行时间,SCHEDULED_TIME 则会显示重新计划的运行时间。. . 注意,在重试之前,RUN_ID 可能不是当前任务/图形运行的唯一标识符。您可以使用 GRAPH_RUN_GROUP_ID 列来代替 RUN_ID。 |
ATTEMPT_NUMBER |
NUMBER |
整数表示尝试运行此任务的次数。最初的一次。 |
SCHEDULED_FROM |
TEXT |
其中之一:
对于任务图中子任务的运行,该列返回与根任务运行相同的值。 |
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;