snowflake.core.task.TaskCollection

class snowflake.core.task.TaskCollection(schema: SchemaResource)

Bases: SchemaObjectCollectionParent[TaskResource]

Represents the collection operations of the Snowflake Task resource.

Example

>>> tasks: TaskCollection = root.databases["mydb"].schemas["myschema"].tasks
>>> mytask = tasks.create(Task("mytask", definition="select 1"))  # returns a TaskResource instance.
>>> task_iter = tasks.iter(like="my%")
Copy

Attributes

database
root
schema

Methods

__init__(schema: SchemaResource) None
create(task: Task, *, mode: CreateMode = CreateMode.error_if_exists) TaskResource

Create a task in the Snowflake database.

Parameters:
  • task – an instance of Task.

  • mode

    One of the following strings.

    CreateMode.error_if_exists: Throw an snowflake.core.exceptions.ConflictError if the task already exists in Snowflake. Equivalent to SQL create task <name> ....

    CreateMode.or_replace: Replace if the task already exists in Snowflake. Equivalent to SQL create or replace task <name> ....

    CreateMode.if_not_exists: Do nothing if the task already exists in Snowflake. Equivalent to SQL create task <name> if not exists...

    Default value is CreateMode.error_if_exists.

items() ItemsView[str, T]
iter(*, like: str | None = None, starts_with: str | None = None, limit: int | None = None, root_only: bool = False) PagedIter[Task]

Search for tasks in Snowflake.

Parameters:
  • like – The pattern of the Task name. Use % to represent any number of characters and ? for a single character.

  • startswith – The task name starts with this string.

  • root_only – Look for root tasks only.

keys() KeysView[str]
values() ValuesView[T]