Schéma :

ACCOUNT_USAGE

Vue TASK_VERSIONS

Cette vue Account Usage vous permet de récupérer l’historique des versions de tâches. Les lignes renvoyées indiquent les tâches qui composaient un graphique de tâches et leurs propriétés à un moment donné.

Colonnes

Nom de la colonne

Type de données

Description

ROOT_TASK_ID

TEXT

Identificateur unique de la tâche racine dans un DAG. Cet ID correspond à la valeur de la colonne ID dans la sortie SHOW TASKS pour la même tâche. Correspond à ROOT_TASK_ID dans COMPLETE_TASK_GRAPHS et TASK_HISTORY.

GRAPH_VERSION

NUMBER

Nombre entier identifiant la version de la tâche. Correspond à GRAPH_VERSION dans COMPLETE_TASK_GRAPHS.

GRAPH_VERSION_CREATED_ON

TIMESTAMP_LTZ

Date et heure auxquelles cette version du graphique des tâches a été enregistrée.

NAME

TEXT

Nom de la tâche.

ID

TEXT

Identificateur unique pour chaque tâche. Notez que recréer une tâche (en utilisant CREATE OR REPLACE TASK) crée essentiellement une nouvelle tâche, qui a un nouveau ID.

DATABASE_ID

NUMBER

Identificateur interne/généré par le système pour la base de données contenant la tâche.

DATABASE_NAME

TEXT

Nom de la base de données dans laquelle la tâche est stockée.

SCHEMA_ID

NUMBER

Identificateur interne/généré par le système pour le schéma contenant la tâche.

SCHEMA_NAME

TEXT

Nom du schéma dans lequel la tâche est stockée.

OWNER

TEXT

Rôle qui possède la tâche (c.-à-d. qui dispose du privilège OWNERSHIP sur la tâche)

COMMENT

TEXT

Commentaire pour la tâche.

WAREHOUSE_NAME

TEXT

Entrepôt virtuel qui fournit les ressources requises pour exécuter la tâche.

SCHEDULE

TEXT

Planifiez l’exécution de la tâche. Affiche NULL si aucune planification n’est spécifiée.

PREDECESSORS

ARRAY

Tableau JSON de toutes les tâches identifiées dans le paramètre AFTER de la tâche (c’est-à-dire les tâches prédécesseurs). Lorsqu’elles sont exécutées avec succès jusqu’à leur terme, ces tâches déclenchent la tâche en cours. Les noms des tâches individuelles dans le tableau sont entièrement qualifiés (c’est-à-dire qu’ils incluent les noms de la base de données et du schéma du conteneur). Affiche un tableau vide si la tâche n’a pas de prédécesseur.

STATE

TEXT

État actuel de la tâche : started ou suspended. NULL pour les tâches racines (tâches sans prédécesseurs).

DEFINITION

TEXT

Instructions SQL exécutées lors de l’exécution de la tâche.

CONDITION_TEXT

TEXT

Condition spécifiée dans la clause WHEN pour la tâche.

ALLOW_OVERLAPPING_EXECUTION

BOOLEAN

Pour les tâches racines d’un DAG, affiche TRUE si le chevauchement de l’exécution du DAG est explicitement autorisé. Pour les tâches enfants dans un DAG, affiche NULL.

ERROR_INTEGRATION

TEXT

Nom de l’intégration de notification utilisée pour accéder à Amazon Simple Notification Service (SNS) afin de relayer les notifications d’erreur pour la tâche.

LAST_COMMITTED_ON

TIMESTAMP_LTZ

Horodatage de la dernière version définie pour la tâche. Si aucune version n’a été définie (c’est-à-dire si la tâche n’a pas été reprise ou exécutée manuellement après sa création), la valeur est NULL.

LAST_SUSPENDED_ON

TIMESTAMP_LTZ

Horodatage de la dernière suspension de la tâche. Si la tâche n’a pas encore été suspendue, la valeur est NULL.

CONFIG

TEXT

Affiche la configuration du niveau graphique si elle est définie pour la tâche racine, sinon affiche NULL.

OWNER_ROLE_TYPE

TEXT

Type de rôle qui possède l’objet, soit ROLE ou DATABASE_ROLE. . Si une Snowflake Native App est propriétaire de l’objet, la valeur est APPLICATION. . Snowflake renvoie NULL si vous supprimez l’objet, car un objet supprimé n’a pas de rôle propriétaire.

Notes sur l’utilisation

La latence pour la vue peut atteindre 3 heures.

Exemples

Récupérer les tâches d’un graphique de tâches spécifique en fonction des ROOT_TASK_ID et GRAPH_VERSION :

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

Récupérer les exécutions de tâches pour un graphique de tâches particulier et ses tâches descendantes à partir de task_history, avec des informations supplémentaires sur les tâches à partir de task_versions.

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'
Copy