Categorias:: Information Schema , Funções de tabela

CURRENT_TASK_GRAPHS¶

Retorna o status de uma execução de gráfico que está atualmente programada ou em execução. Um gráfico é atualmente definido como uma única tarefa programada ou um DAG de tarefas compostas por uma tarefa raiz programada e uma ou mais tarefas filho (isto é, tarefas que têm uma tarefa predecessora definida). Para os propósitos desta função, tarefa raiz refere-se à tarefa única programada ou à tarefa raiz em um DAG.

Esta função retorna detalhes para execuções de gráficos que estão atualmente em execução ou que estão programadas para serem executadas nos próximos 8 dias. Para recuperar os detalhes das execuções do gráfico concluídas nos últimos 60 minutos, consulte a função de tabela COMPLETE_TASK_GRAPHS.

A função retorna os detalhes da execução do gráfico para toda sua conta Snowflake ou uma tarefa raiz especificada.

Sintaxe¶

CURRENT_TASK_GRAPHS(
      [ RESULT_LIMIT => <integer> ]
      [, ROOT_TASK_NAME => '<string>' ] )

Copy

Argumentos¶

Todos os argumentos são opcionais.

RESULT_LIMIT => integer

Um número especificando o número máximo de linhas retornadas pela função. Note que os resultados são devolvidos em ordem decrescente de SCHEDULED_TIME. Se o número de linhas correspondentes for maior do que o limite de resultados, as execuções do gráfico com o carimbo de data/hora mais recente programado serão devolvidas, até o limite especificado.

Intervalo: 1 a 10000

Padrão: 1000

ROOT_TASK_NAME => string

Uma cadeia de caracteres que não diferencia maiúsculas e minúsculas, especificando o nome da tarefa raiz. Somente nomes de tarefas não qualificadas são suportados. Somente as execuções de gráfico para a tarefa especificada são retornadas. Observe que se várias tarefas tiverem o mesmo nome, a função retorna a execução de gráfico para cada uma dessas tarefas.

Notas de uso¶

Retorna resultados somente para a função ACCOUNTADMIN, o proprietário da tarefa (ou seja, a função com o privilégio OWNERSHIP para a tarefa) ou uma função com o privilégio global MONITOR EXECUTION. Observe que a menos que uma função com o privilégio MONITOR EXECUTION também tenha o privilégio USAGE no banco de dados e esquema que armazena a tarefa, os valores DATABASE_NAME e SCHEMA_NAME na saída serão NULL.
Quando a função CURRENT_TASK_GRAPHS é consultada, seu nome de tarefa e os argumentos de limite de resultado são aplicados primeiro, seguido da cláusula WHERE e LIMIT, respectivamente, se especificado. Além disso, a função CURRENT_TASK_GRAPHS retorna registros em ordem decrescente SCHEDULED_TIME.

Na prática, se você tiver muitos gráficos de tarefas rodando em sua conta, os resultados retornados pela função poderiam incluir apenas tarefas programadas, especialmente se o valor RESULT_LIMIT for relativamente baixo.
Ao chamar uma função de tabela do Information Schema, a sessão deve ter um esquema INFORMATION_SCHEMA em uso ou o nome da função deve ser totalmente qualificado. Para obter mais detalhes, consulte Snowflake Information Schema.

Saída¶

A função retorna as seguintes colunas:

Nome da coluna	Tipo de dados	Descrição
ROOT_TASK_NAME	TEXT	Nome da tarefa raiz.
DATABASE_NAME	TEXT	Nome do banco de dados que contém o gráfico.
SCHEMA_NAME	TEXT	Nome do esquema que contém o gráfico.
STATE	TEXT	Estado da execução do gráfico: `SCHEDULED`: a tarefa raiz é programada em um momento futuro. `EXECUTING`: pelo menos uma execução de tarefa no gráfico ainda está sendo executada, ou a tarefa raiz foi executada com sucesso até a conclusão e uma ou mais tarefas filho estão programadas. Observe que se o estado da execução da tarefa raiz for SKIPPED, a função não retorna uma linha para a execução.
FIRST_ERROR_TASK_NAME	TEXT	Nome da primeira tarefa no gráfico que retornou um erro; retorna NULL se nenhuma tarefa produziu um erro.
FIRST_ERROR_CODE	NUMBER	Código de erro do erro retornado pela tarefa nomeada em FIRST_ERROR_TASK_NAME; retorna NULL se nenhuma tarefa produziu um erro.
FIRST_ERROR_MESSAGE	TEXT	Mensagem de erro do erro retornado pela tarefa nomeada em FIRST_ERROR_TASK_NAME; retorna NULL se nenhuma tarefa produziu um erro.
SCHEDULED_TIME	TIMESTAMP_LTZ	Hora em que a tarefa raiz está/estava programada para começar a execução. Note que fazemos o melhor para assegurar uma precisão absoluta, mas só garantimos que as tarefas não sejam executadas antes do horário programado.
QUERY_START_TIME	TIMESTAMP_LTZ	Horário em que a consulta na definição da tarefa raiz começou a ser executada. Este carimbo de data/hora se alinha à hora de início da consulta retornada por QUERY_HISTORY.
NEXT_SCHEDULED_TIME	TIMESTAMP_LTZ	Hora em que a tarefa autônoma ou raiz (em um DAG) é a próxima programada para começar a funcionar, assumindo que a execução atual da tarefa autônoma ou DAG iniciada na hora SCHEDULED_TIME é concluída a tempo.
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.
GRAPH_VERSION	NUMBER	Número inteiro que identifica a versão do DAG que foi executado ou que está programado para ser executado.
RUN_ID	NUMBER	Hora em que a tarefa autônoma ou raiz em um DAG está/estava originalmente programada para começar a execução. O formato é hora de época (em milissegundos). A combinação dos valores ROOT_TASK_ID e RUN_ID identifica uma execução específica de um DAG. . Horário programado original refere-se a raros casos em que o sistema pode reprogramar a mesma tarefa para ser executada em um horário diferente a fim de tentar novamente ou reequilibrar a carga. Se isso acontecer, RUN_ID mostra o tempo de execução programado original e SCHEDULED_TIME mostra o tempo de execução reprogramado.

Exemplos¶

Recuperar as 1.000 execuções mais recentes da gráfico (concluída, ainda em execução ou programada no futuro) na conta. Observe que o número máximo de linhas retornadas pela função é limitado a 1000 por padrão. Para alterar o número de linhas devolvidas, modifique o valor do argumento RESULT_LIMIT:

select *
  from table(information_schema.current_task_graphs())
  order by scheduled_time;

Copy

Recuperar os 10 execuções mais recentes de gráfico para uma tarefa específica (ainda em execução ou programada no futuro):

select *
  from table(information_schema.current_task_graphs(
    result_limit => 10,
    root_task_name=>'MYTASK'));

Copy