- Schéma :
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 : |
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 |
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;
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'