- Esquema:
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 gráfico de tarefas 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 Exibição COMPLETE_TASK_GRAPHS e Exibição TASK_HISTORY. |
GRAPH_VERSION | NUMBER | Número inteiro que identifica a versão da tarefa. Corresponde a GRAPH_VERSION em Exibição 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 que possui a tarefa (ou seja, tem 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 (ou seja, tarefas predecessoras). Quando executadas com sucesso até a conclusão, estas tarefas acionam a tarefa atual. Os nomes das tarefas individuais na matriz são totalmente qualificados (ou seja, incluem o banco de dados do contêiner e os nomes do esquema). Exibe uma matriz vazia se a tarefa não tiver um predecessor. |
STATE | TEXT | Estado atual da tarefa: |
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), Google Pub/Sub ou Microsoft Azure Event Grid 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 (ou seja, 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. |
TARGET_COMPLETION_INTERVAL | TEXT | A janela de tempo em que a tarefa deve ser executada. Usado apenas para tarefas sem servidor. Opcional para tarefas sem servidor, necessário para tarefas acionadas sem servidor. |
SCHEDULING_MODE | TEXT | Reservado para funcionalidade futura. Exibe UNKNOWN. |
Notas de uso¶
A latência da visualização pode ser de até 3 horas.
Exemplos¶
Recupere as tarefas de um gráfico de tarefas específico 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 gráfico de tarefas 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'