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 DAG 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.

Notes sur l’utilisation¶

La latence pour la vue peut atteindre 3 heures.

Exemples¶

Récupérer les tâches d’un DAG de tâche 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 DAG de tâche 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