complete_graphs
Creates, updates, deletes, gets or lists a complete_graphs
resource.
Overview
Name | complete_graphs |
Type | Resource |
Id | snowflake.task.complete_graphs |
Fields
Name | Datatype | Description |
---|---|---|
completed_time | string | The time this task run was last completed. |
database_name | string | The name of the current database for the task run. |
first_error_code | integer | The first error code thrown in the task run. |
first_error_message | string | The first error message thrown in the task run. |
first_error_task_name | string | The name of the first task throwing an error in the task run. |
graph_version | integer | The current version of the DAG on the task run. |
next_scheduled_time | string | The next upcoming time for the task run. |
query_start_time | string | The start time for the task run query. |
root_task_id | string | The unique task ID for the root task. |
root_task_name | string | The name of the root task in the current task run. |
run_id | integer | The unique ID for the current task run. |
scheduled_time | string | The scheduled time for the task run. |
schema_name | string | The name of the current schema for the task run. |
state | string | The current state of the task run. |
Methods
Name | Accessible by | Required Params | Description |
---|---|---|---|
get_complete_graphs | SELECT | database_name, name, schema_name, endpoint | This function returns details for graph runs that are completed. |
get_complete_graphs_deprecated | SELECT | database_name, name, schema_name, endpoint | This function returns details for graph runs that are completed. |
SELECT
examples
This function returns details for graph runs that are completed.
SELECT
completed_time,
database_name,
first_error_code,
first_error_message,
first_error_task_name,
graph_version,
next_scheduled_time,
query_start_time,
root_task_id,
root_task_name,
run_id,
scheduled_time,
schema_name,
state
FROM snowflake.task.complete_graphs
WHERE database_name = '{{ database_name }}'
AND name = '{{ name }}'
AND schema_name = '{{ schema_name }}'
AND endpoint = '{{ endpoint }}';