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.