airflow_pydantic.Task

pydantic model airflow_pydantic.Task

Bases: TaskArgs, TaskRenderMixin, TaskInstantiateMixin

field task_id: str | None = None

a unique, meaningful id for the task

field operator: Annotated[type, BeforeValidator(func=get_import_path, json_schema_input_type=PydanticUndefined), PlainSerializer(func=serialize_path_as_string, return_type=str, when_used=json)] [Required]

airflow operator path

field dependencies: list[str | Task] | list[str | tuple[str, str] | tuple[Task, str]] | None = None

dependencies

set_upstream(other: Task | list[Task])

set_downstream(other: Task | list[Task])