snowflake.core.task.dagv1.DAGTask¶

class snowflake.core.task.dagv1.DAGTask(name: str, definition: str | Callable[[...], Any] | StoredProcedureCall, *, condition: str | None = None, warehouse: str | None = None, session_parameters: Dict[str, Any] | None = None, user_task_managed_initial_warehouse_size: str | None = None, user_task_timeout_ms: int | None = None, error_integration: str | None = None, comment: str | None = None, dag: DAG | None = None)¶

Bases: object

Represents a child Task of a task graph.

A child task has a subset of properties of snowflake.core.task.Task. For instance, it doesn’t have schedule because it’s triggered after the prececessors are finished.

Refer to snowflake.core.task.Task for the details of each property.

Attributes

dag¶

Return the DAG of this task.

full_name¶

The full name of the child task.

predecessors¶

Return the predecessors of the Task.

name¶

Name of the Task.

definition¶

refer to snowflake.core.task.Task.definition.

condition¶

refer to snowflake.core.task.Task.condition.

error_integration¶

refer to snowflake.core.task.Task.error_integration.

session_parameters¶

refer to snowflake.core.task.Task.session_parameter.

comment¶

comment for the task.

user_task_timeout_ms¶

refer to snowflake.core.task.user_task_timeout_ms

Methods

__init__(name: str, definition: str | Callable[[...], Any] | StoredProcedureCall, *, condition: str | None = None, warehouse: str | None = None, session_parameters: Dict[str, Any] | None = None, user_task_managed_initial_warehouse_size: str | None = None, user_task_timeout_ms: int | None = None, error_integration: str | None = None, comment: str | None = None, dag: DAG | None = None) → None¶

add_predecessors(other: DAGTask | Iterable[DAGTask | Callable[[Session], str | None]] | Callable[[Session], str | None]) → None¶

Add a task or a task list to the direct predecessors of the current task.

add_successors(other: DAGTask | Iterable[DAGTask | Callable[[Session], str | None]] | Callable[[Session], str | None]) → None¶

Add a task or a task list to be the direct successor of the current task.