Esquema:

ACCOUNT_USAGE

Exibição TASK_VERSIONS

Esta exibição do Account Usage permite que você recupere o histórico de versões da tarefa. As linhas retornadas indicam as tarefas que compreendiam um DAG e suas propriedades em um determinado momento.

Colunas

Nome da coluna

Tipo de dados

Descrição

ROOT_TASK_ID

TEXT

Identificador exclusivo para a tarefa raiz em um DAG. Esta ID corresponde ao valor da coluna ID na saída SHOW TASKS para a mesma tarefa. Corresponde a ROOT_TASK_ID em COMPLETE_TASK_GRAPHS e TASK_HISTORY.

GRAPH_VERSION

NUMBER

Número inteiro que identifica a versão da tarefa. Corresponde a GRAPH_VERSION em COMPLETE_TASK_GRAPHS.

GRAPH_VERSION_CREATED_ON

TIMESTAMP_LTZ

Data e hora em que esta versão do gráfico da tarefa foi salva.

NAME

TEXT

Nome da tarefa.

ID

TEXT

Identificador exclusivo para cada tarefa. Note que recriar uma tarefa (usando CREATE OR REPLACE TASK) essencialmente cria uma nova tarefa, que tem uma nova ID.

DATABASE_ID

NUMBER

Identificador interno/gerado pelo sistema para o banco de dados que continha a tarefa.

DATABASE_NAME

TEXT

Nome do banco de dados no qual a tarefa é armazenada.

SCHEMA_ID

NUMBER

Identificador interno/gerado pelo sistema para o esquema que continha a tarefa.

SCHEMA_NAME

TEXT

Nome do esquema no qual a tarefa é armazenada.

OWNER

TEXT

Função proprietária da tarefa (ou seja, com o privilégio OWNERSHIP na tarefa)

COMMENT

TEXT

Comentário para a tarefa.

WAREHOUSE_NAME

TEXT

Warehouse que fornece os recursos necessários para a execução da tarefa.

SCHEDULE

TEXT

Cronograma para a execução da tarefa. Exibe NULL se nenhum cronograma for especificado.

PREDECESSORS

ARRAY

Matriz JSON de quaisquer tarefas identificadas no parâmetro AFTER para a tarefa (isto é, tarefas predecessoras). Quando executadas com sucesso até a conclusão, estas tarefas acionam a tarefa atual. Os nomes de tarefas individuais na matriz são totalmente qualificados (ou seja, inclui o banco de dados do contêiner e os nomes de esquema). Exibe uma matriz vazia se a tarefa não tiver um predecessor.

STATE

TEXT

Estado atual da tarefa: started ou suspended. NULL para tarefas raiz (tarefas sem antecessores).

DEFINITION

TEXT

Instruções SQL executadas quando a tarefa é executada.

CONDITION_TEXT

TEXT

Condição especificada na cláusula WHEN para a tarefa.

ALLOW_OVERLAPPING_EXECUTION

BOOLEAN

Para tarefas raiz em um DAG, exibe TRUE se a execução sobreposta do DAG for explicitamente permitida. Para tarefas filho em um DAG, exibe NULL.

ERROR_INTEGRATION

TEXT

Nome da integração de notificação utilizada para acessar o Amazon Simple Notification Service (SNS) para retransmitir notificações de erro para a tarefa.

LAST_COMMITTED_ON

TIMESTAMP_LTZ

Carimbo de data/hora quando uma versão da tarefa foi definida pela última vez. Se nenhuma versão tiver sido definida (isto é, se a tarefa não foi retomada ou executada manualmente após ter sido criada), o valor é NULL.

LAST_SUSPENDED_ON

TIMESTAMP_LTZ

Carimbo de data/hora quando a tarefa foi suspensa pela última vez. Se a tarefa ainda não foi suspensa, o valor será NULL.

Notas de uso

A latência da visualização pode ser de até 3 horas.

Exemplos

Recupere as tarefas de um DAG de tarefa específica com base nos ROOT_TASK_ID e GRAPH_VERSION:

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

Recupere as execuções de tarefa para um DAG de tarefa especial e suas tarefas descendentes do histórico_tarefa, com informações adicionais da tarefa de versões_tarefa.

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'