current_graphs

Creates, updates, deletes, gets or lists a current_graphs resource.

Overview

Name	current_graphs
Type	Resource
Id	snowflake.task.current_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_current_graphs	SELECT	database_name, name, schema_name, endpoint	This function returns details for graph runs that are currently executing or are next scheduled to run within the next 8 days.
get_current_graphs_deprecated	SELECT	database_name, name, schema_name, endpoint	This function returns details for graph runs that are currently executing or are next scheduled to run within the next 8 days.

SELECT examples

This function returns details for graph runs that are currently executing or are next scheduled to run within the next 8 days.

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.current_graphs
WHERE database_name = '{{ database_name }}'
AND name = '{{ name }}'
AND schema_name = '{{ schema_name }}'
AND endpoint = '{{ endpoint }}';