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