airflow-pydantic

Pydantic models for Apache Airflow

Overview

Pydantic models of Apache Airflow data structures.

Core

• DAG / DAG Arguments

• Task / Task Arguments

Operators

• ApprovalOperator

• BashOperator

• BranchDayOfWeekOperator

• BranchExternalPythonOperator

• BranchPythonOperator

• BranchPythonVirtualenvOperator

• EmptyOperator

• ExternalPythonOperator

• ExternalTaskMarker

• HITLEntryOperator

• HITLOperator

• HITLBranchOperator

• PythonOperator

• PythonVirtualenvOperator

• ShortCircuitOperator

• SSHOperator

• TriggerDagRunOperator

Sensors

• BashSensor

• DateTimeSensor

• DateTimeSensorAsync

• DayOfWeekSensor

• ExternalTaskSensor

• FileSensor

• PythonSensor

• TimeSensor

• WaitSensor

Other

• Param

• Pool

• SSHHook

• Variable

• CronDataIntervalTimetable

• CronTriggerTimetable

• DeltaDataIntervalTimetable

• DeltaTriggerTimetable

• EventsTimetable

• MultipleCronTriggerTimetable

Usage

All operators and sensors support two methods:

• instantiate(): Create a concrete Airflow instance

• render(): Return Python code to instantiate the instance, for use in airflow-config

Note

This library was generated using copier from the Base Python Project Template repository.