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, is_finalizer: bool | 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.

Methods

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.

Parameters:

other (Union[DAGTask, Iterable[DAGTask], Callable[["Session"], Optional[str]]]) – The task or task list to be added as the direct predecessors of the current task.

Examples

Add a task to the predecessors of the current task:

>>> task1 = DAGTask("task1", "select 'task1'")
>>> task2 = DAGTask("task2", "select 'task2'")
>>> task1.add_predecessors(task2)
Copy
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.

Parameters:

other (Union[DAGTask, Iterable[DAGTask], Callable[["Session"], Optional[str]]]) – The task or task list to be added as the direct successors of the current task.

Examples

Add a task to the successors of the current task:

>>> task1 = DAGTask("task1", "select 'task1'")
>>> task2 = DAGTask("task2", "select 'task2'")
>>> task1.add_successors(task2)
Copy
Language: English