airflow_pydantic.Task

pydantic model airflow_pydantic.Task

Bases: TaskArgs

Show JSON schema

{
   "title": "Task",
   "type": "object",
   "properties": {
      "owner": {
         "anyOf": [
            {
               "type": "string"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "the owner of the task. Using a meaningful description (e.g. user/person/team/role name) to clarify ownership is recommended.",
         "title": "Owner"
      },
      "email": {
         "anyOf": [
            {
               "items": {
                  "type": "string"
               },
               "type": "array"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "the 'to' email address(es) used in email alerts",
         "title": "Email"
      },
      "email_on_failure": {
         "anyOf": [
            {
               "type": "boolean"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "Indicates whether email alerts should be sent when a task failed",
         "title": "Email On Failure"
      },
      "email_on_retry": {
         "anyOf": [
            {
               "type": "boolean"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "Indicates whether email alerts should be sent when a task is retried",
         "title": "Email On Retry"
      },
      "retries": {
         "anyOf": [
            {
               "type": "integer"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "the number of retries that should be performed before failing the task",
         "title": "Retries"
      },
      "retry_delay": {
         "anyOf": [
            {
               "format": "duration",
               "type": "string"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "delay between retries",
         "title": "Retry Delay"
      },
      "start_date": {
         "anyOf": [
            {
               "format": "date-time",
               "type": "string"
            },
            {
               "maxItems": 2,
               "minItems": 2,
               "prefixItems": [
                  {
                     "format": "date-time",
                     "type": "string"
                  },
                  {
                     "type": "string"
                  }
               ],
               "type": "array"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "The start_date for the task, determines the execution_date for the first task instance. The best practice is to have the start_date rounded to your DAG\u2019s schedule_interval. Daily jobs have their start_date some day at 00:00:00, hourly jobs have their start_date at 00:00 of a specific hour. Note that Airflow simply looks at the latest execution_date and adds the schedule_interval to determine the next execution_date. It is also very important to note that different tasks\u2019 dependencies need to line up in time. If task A depends on task B and their start_date are offset in a way that their execution_date don\u2019t line up, A\u2019s dependencies will never be met. If you are looking to delay a task, for example running a daily task at 2AM, look into the TimeSensor and TimeDeltaSensor. We advise against using dynamic start_date and recommend using fixed ones. Read the FAQ entry about start_date for more information.",
         "title": "Start Date"
      },
      "end_date": {
         "anyOf": [
            {
               "format": "date-time",
               "type": "string"
            },
            {
               "maxItems": 2,
               "minItems": 2,
               "prefixItems": [
                  {
                     "format": "date-time",
                     "type": "string"
                  },
                  {
                     "type": "string"
                  }
               ],
               "type": "array"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "if specified, the scheduler won\u2019t go beyond this date",
         "title": "End Date"
      },
      "depends_on_past": {
         "anyOf": [
            {
               "type": "boolean"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "when set to true, task instances will run sequentially and only if the previous instance has succeeded or has been skipped. The task instance for the start_date is allowed to run.",
         "title": "Depends On Past"
      },
      "queue": {
         "anyOf": [
            {
               "type": "string"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "which queue to target when running this job. Not all executors implement queue management, the CeleryExecutor does support targeting specific queues.",
         "title": "Queue"
      },
      "pool": {
         "anyOf": [
            {
               "type": "string"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "the slot pool this task should run in, slot pools are a way to limit concurrency for certain tasks",
         "title": "Pool"
      },
      "pool_slots": {
         "anyOf": [
            {
               "type": "integer"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "the number of pool slots this task should use (>= 1) Values less than 1 are not allowed",
         "title": "Pool Slots"
      },
      "do_xcom_push": {
         "anyOf": [
            {
               "type": "boolean"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "if True, an XCom is pushed containing the Operator\u2019s result",
         "title": "Do Xcom Push"
      },
      "task_display_name": {
         "anyOf": [
            {
               "type": "string"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "The display name of the task which appears on the UI.",
         "title": "Task Display Name"
      },
      "task_id": {
         "anyOf": [
            {
               "type": "string"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "a unique, meaningful id for the task",
         "title": "Task Id"
      },
      "operator": {
         "default": null,
         "title": "Operator"
      },
      "dependencies": {
         "anyOf": [
            {
               "items": {
                  "type": "string"
               },
               "type": "array"
            },
            {
               "type": "null"
            }
         ],
         "default": null,
         "description": "dependencies",
         "title": "Dependencies"
      },
      "args": {
         "anyOf": [
            {
               "$ref": "#/$defs/_TaskSpecificArgs"
            },
            {
               "type": "null"
            }
         ],
         "default": null
      }
   },
   "$defs": {
      "_TaskSpecificArgs": {
         "properties": {},
         "title": "_TaskSpecificArgs",
         "type": "object"
      }
   },
   "additionalProperties": true
}

Fields:

• args (airflow_pydantic.task._TaskSpecificArgs | None)

• dependencies (List[str] | None)

• operator (type)

• task_id (str | None)

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)] [Required]

airflow operator path

field dependencies: List[str] | None = None

dependencies

field args: _TaskSpecificArgs | None = None

instantiate(dag, **kwargs)