Community
Meetups
Documentation
Use-cases
Announcements
Blog
Ecosystem
Community
Meetups
Documentation
Use-cases
Announcements
Blog
Ecosystem
Content
Version:
2.8.0
Content
Overview
Quick Start
Installation of Apache Airflow®
Security
Tutorials
How-to Guides
UI / Screenshots
Core Concepts
Authoring and Scheduling
Administration and Deployment
Integration
Public Interface of Airflow
Best Practices
FAQ
Release Policies
Release Notes
Privacy Notice
Project
License
References
Operators and hooks
CLI
Templates
Stable REST API
Deprecated REST API
Configurations
Extra packages
Internal DB details
Database Migrations
Database ERD Schema
Version:
2.8.0
Content
Overview
Quick Start
Installation of Apache Airflow®
Security
Tutorials
How-to Guides
UI / Screenshots
Core Concepts
Authoring and Scheduling
Administration and Deployment
Integration
Public Interface of Airflow
Best Practices
FAQ
Release Policies
Release Notes
Privacy Notice
Project
License
References
Operators and hooks
CLI
Templates
Stable REST API
Deprecated REST API
Configurations
Extra packages
Internal DB details
Database Migrations
Database ERD Schema
Home
Index
Index
_
|
A
|
B
|
C
|
D
|
E
|
F
|
G
|
H
|
I
|
J
|
K
|
L
|
M
|
N
|
O
|
P
|
Q
|
R
|
S
|
T
|
U
|
V
|
W
|
X
|
Y
_
__attrs_post_init__() (airflow.decorators.base.DecoratedMappedOperator method)
(airflow.sensors.external_task.ExternalTaskSensorLink method)
__bool__() (airflow.models.param.ParamsDict method)
(airflow.sensors.base.PokeReturnValue method)
__call__ (airflow.decorators.base.Task attribute)
(airflow.decorators.TaskDecoratorCollection attribute)
__call__() (airflow.decorators.base.TaskDecorator method)
__contains__() (airflow.models.param.ParamsDict method)
__copy__() (airflow.models.param.Param method)
(airflow.models.param.ParamsDict method)
__deepcopy__() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.dag.DAG method)
(airflow.models.param.ParamsDict method)
__delitem__() (airflow.models.param.ParamsDict method)
__enter__() (airflow.decorators.setup_teardown.ContextWrapper method)
(airflow.models.dag.DAG method)
__eq__() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.dag.DAG method)
(airflow.models.param.ParamsDict method)
(airflow.models.taskinstance.SimpleTaskInstance method)
(airflow.timetables._cron.CronMixin method)
(airflow.timetables.interval.DeltaDataIntervalTimetable method)
(airflow.triggers.base.TriggerEvent method)
__exit__() (airflow.decorators.setup_teardown.ContextWrapper method)
(airflow.models.dag.DAG method)
__getattr__() (airflow.decorators.TaskDecoratorCollection method)
__getitem__() (airflow.models.param.ParamsDict method)
__getstate__() (airflow.models.baseoperator.BaseOperator method)
__gt__() (airflow.models.baseoperator.BaseOperator method)
__hash__() (airflow.decorators.base.DecoratedMappedOperator method)
(airflow.models.baseoperator.BaseOperator method)
(airflow.models.dag.DAG method)
(airflow.models.taskinstance.TaskInstance method)
__iter__() (airflow.models.param.ParamsDict method)
__len__() (airflow.models.param.ParamsDict method)
__lt__() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.dag.DAG method)
__ne__() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.dag.DAG method)
__or__() (airflow.models.baseoperator.BaseOperator method)
__repr__() (airflow.exceptions.TaskDeferred method)
(airflow.models.baseoperator.BaseOperator method)
(airflow.models.connection.Connection method)
(airflow.models.dag.DAG method)
(airflow.models.dag.DagModel method)
(airflow.models.dag.DagOwnerAttributes method)
(airflow.models.dag.DagTag method)
(airflow.models.dagrun.DagRun method)
(airflow.models.dagrun.DagRunNote method)
(airflow.models.param.ParamsDict method)
(airflow.models.taskinstance.TaskInstance method)
(airflow.models.taskinstance.TaskInstanceNote method)
(airflow.models.variable.Variable method)
(airflow.models.xcom.BaseXCom method)
(airflow.timetables.events.EventsTimetable method)
(airflow.triggers.base.BaseTrigger method)
(airflow.triggers.base.TriggerEvent method)
__setattr__() (airflow.models.baseoperator.BaseOperator method)
__setitem__() (airflow.models.param.ParamsDict method)
__setstate__() (airflow.models.baseoperator.BaseOperator method)
__slots__ (airflow.models.param.ParamsDict attribute)
__str__() (airflow.exceptions.AirflowDagDuplicatedIdException method)
(airflow.exceptions.AirflowFileParseException method)
(airflow.exceptions.DeserializingResultError method)
(airflow.exceptions.FailStopDagInvalidTriggerRule method)
(airflow.exceptions.FileSyntaxError method)
(airflow.exceptions.TaskAlreadyInTaskGroup method)
(airflow.exceptions.UnmappableXComLengthPushed method)
(airflow.exceptions.UnmappableXComTypePushed method)
(airflow.exceptions.XComForMappingNotPushed method)
(airflow.exceptions.XComNotFound method)
(airflow.models.dag.InconsistentDataInterval method)
(airflow.utils.state.DagRunState method)
(airflow.utils.state.JobState method)
(airflow.utils.state.TaskInstanceState method)
__table_args__ (airflow.models.dag.DagModel attribute)
(airflow.models.dagrun.DagRun attribute)
(airflow.models.dagrun.DagRunNote attribute)
(airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
(airflow.models.xcom.BaseXCom attribute)
__tablename__ (airflow.models.connection.Connection attribute)
(airflow.models.dag.DagModel attribute)
(airflow.models.dag.DagOwnerAttributes attribute)
(airflow.models.dag.DagTag attribute)
(airflow.models.dagrun.DagRun attribute)
(airflow.models.dagrun.DagRunNote attribute)
(airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
(airflow.models.variable.Variable attribute)
(airflow.models.xcom.BaseXCom attribute)
__version__ (airflow.models.param.Param attribute)
(airflow.models.param.ParamsDict attribute)
__wrapped__ (airflow.decorators.base.Task property)
A
access_control (airflow.models.dag.DAG property)
active_runs_limit (airflow.timetables.base.Timetable attribute)
(airflow.timetables.simple.ContinuousTimetable attribute)
active_runs_of_dags() (airflow.models.dagrun.DagRun class method)
add_inlets() (airflow.models.baseoperator.BaseOperator method)
add_one() (in module airflow.example_dags.example_dynamic_task_mapping)
add_one_task (in module airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators)
add_outlets() (airflow.models.baseoperator.BaseOperator method)
add_task() (airflow.models.dag.DAG method)
add_tasks() (airflow.models.dag.DAG method)
AddOneOperator (class in airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators)
adoptable_states (airflow.utils.state.State attribute)
AfterWorkdayTimetable (class in airflow.example_dags.plugins.workday)
airflow.decorators
module
airflow.decorators.base
module
airflow.decorators.branch_external_python
module
airflow.decorators.branch_python
module
airflow.decorators.branch_virtualenv
module
airflow.decorators.external_python
module
airflow.decorators.python
module
airflow.decorators.python_virtualenv
module
airflow.decorators.sensor
module
airflow.decorators.setup_teardown
module
airflow.decorators.short_circuit
module
airflow.decorators.task_group
module
airflow.example_dags
module
airflow.example_dags.example_bash_operator
module
airflow.example_dags.example_branch_datetime_operator
module
airflow.example_dags.example_branch_day_of_week_operator
module
airflow.example_dags.example_branch_labels
module
airflow.example_dags.example_branch_operator
module
airflow.example_dags.example_branch_operator_decorator
module
airflow.example_dags.example_branch_python_dop_operator_3
module
airflow.example_dags.example_complex
module
airflow.example_dags.example_datasets
module
airflow.example_dags.example_dynamic_task_mapping
module
airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators
module
airflow.example_dags.example_external_task_marker_dag
module
airflow.example_dags.example_kubernetes_executor
module
airflow.example_dags.example_latest_only
module
airflow.example_dags.example_latest_only_with_trigger
module
airflow.example_dags.example_local_kubernetes_executor
module
airflow.example_dags.example_nested_branch_dag
module
airflow.example_dags.example_params_trigger_ui
module
airflow.example_dags.example_params_ui_tutorial
module
airflow.example_dags.example_passing_params_via_test_command
module
airflow.example_dags.example_python_decorator
module
airflow.example_dags.example_python_operator
module
airflow.example_dags.example_sensor_decorator
module
airflow.example_dags.example_sensors
module
airflow.example_dags.example_setup_teardown
module
airflow.example_dags.example_setup_teardown_taskflow
module
airflow.example_dags.example_short_circuit_decorator
module
airflow.example_dags.example_short_circuit_operator
module
airflow.example_dags.example_skip_dag
module
airflow.example_dags.example_subdag_operator
module
airflow.example_dags.example_task_group
module
airflow.example_dags.example_task_group_decorator
module
airflow.example_dags.example_time_delta_sensor_async
module
airflow.example_dags.example_trigger_controller_dag
module
airflow.example_dags.example_trigger_target_dag
module
airflow.example_dags.example_xcom
module
airflow.example_dags.example_xcomargs
module
airflow.example_dags.libs
module
airflow.example_dags.libs.helper
module
airflow.example_dags.plugins
module
airflow.example_dags.plugins.event_listener
module
airflow.example_dags.plugins.listener_plugin
module
airflow.example_dags.plugins.workday
module
airflow.example_dags.subdags
module
airflow.example_dags.subdags.subdag
module
airflow.example_dags.tutorial
module
airflow.example_dags.tutorial_dag
module
airflow.example_dags.tutorial_objectstorage
module
airflow.example_dags.tutorial_taskflow_api
module
airflow.example_dags.tutorial_taskflow_api_virtualenv
module
airflow.exceptions
module
airflow.hooks
module
airflow.hooks.base
module
airflow.hooks.dbapi
module
airflow.hooks.filesystem
module
airflow.hooks.package_index
module
airflow.hooks.subprocess
module
airflow.macros
module
airflow.models.baseoperator
module
airflow.models.baseoperatorlink
module
airflow.models.connection
module
airflow.models.dag
module
airflow.models.dagbag
module
airflow.models.dagrun
module
airflow.models.param
module
airflow.models.taskinstance
module
airflow.models.taskinstancekey
module
airflow.models.variable
module
airflow.models.xcom
module
airflow.operators
module
airflow.operators.bash
module
airflow.operators.branch
module
airflow.operators.datetime
module
airflow.operators.email
module
airflow.operators.empty
module
airflow.operators.generic_transfer
module
airflow.operators.latest_only
module
airflow.operators.python
module
airflow.operators.smooth
module
airflow.operators.subdag
module
airflow.operators.trigger_dagrun
module
airflow.operators.weekday
module
airflow.policies
module
airflow.secrets
module
airflow.secrets.base_secrets
module
airflow.secrets.cache
module
airflow.secrets.environment_variables
module
airflow.secrets.local_filesystem
module
airflow.secrets.metastore
module
airflow.sensors
module
airflow.sensors.base
module
airflow.sensors.bash
module
airflow.sensors.date_time
module
airflow.sensors.external_task
module
airflow.sensors.filesystem
module
airflow.sensors.python
module
airflow.sensors.time_delta
module
airflow.sensors.time_sensor
module
airflow.sensors.weekday
module
airflow.timetables
module
airflow.timetables._cron
module
airflow.timetables.base
module
airflow.timetables.events
module
airflow.timetables.interval
module
airflow.timetables.simple
module
airflow.timetables.trigger
module
airflow.triggers
module
airflow.triggers.base
module
airflow.triggers.external_task
module
airflow.triggers.file
module
airflow.triggers.temporal
module
airflow.triggers.testing
module
airflow.utils.state
module
AIRFLOW__{SECTION}__{KEY}
,
[1]
AIRFLOW_CONFIG
AIRFLOW_CONN_{CONN_ID}
,
[1]
AIRFLOW_HOME
AIRFLOW_VAR_{KEY}
AIRFLOW_VAR_{VARIABLE_NAME}
AirflowBadRequest
AirflowClusterPolicyError
AirflowClusterPolicySkipDag
AirflowClusterPolicyViolation
AirflowConfigException
AirflowDagCycleException
AirflowDagDuplicatedIdException
AirflowDagInconsistent
AirflowException
AirflowFailException
AirflowFileParseException
AirflowNotFoundException
AirflowOptionalProviderFeatureException
AirflowProviderDeprecationWarning
AirflowRescheduleException
AirflowSensorTimeout
AirflowSkipException
AirflowTaskTimeout
AirflowTimetableInvalid
AirflowWebServerTimeout
ALL_LEAVES (airflow.operators.subdag.SkippedStatePropagationOptions attribute)
allow_future_exec_dates (airflow.models.dag.DAG property)
ANY_LEAF (airflow.operators.subdag.SkippedStatePropagationOptions attribute)
API (in module airflow.example_dags.tutorial_objectstorage)
aq_fields (in module airflow.example_dags.tutorial_objectstorage)
are_dependencies_met() (airflow.models.taskinstance.TaskInstance method)
are_dependents_done() (airflow.models.taskinstance.TaskInstance method)
as_dict() (airflow.models.taskinstance.SimpleTaskInstance method)
as_json() (airflow.models.connection.Connection method)
autoregistered_dags (airflow.models.dag.DagContext attribute)
B
BackfillUnfinished
bag_dag() (airflow.models.dagbag.DagBag method)
base (in module airflow.example_dags.tutorial_objectstorage)
BaseBranchOperator (class in airflow.operators.branch)
BaseHook (class in airflow.hooks.base)
BaseOperator (class in airflow.models.baseoperator)
BaseOperatorLink (class in airflow.models.baseoperatorlink)
BaseOperatorMeta (class in airflow.models.baseoperator)
BaseSecretsBackend (class in airflow.secrets.base_secrets)
BaseSensorOperator (class in airflow.sensors.base)
BaseTrigger (class in airflow.triggers.base)
BaseXCom (class in airflow.models.xcom)
bash_op1 (in module airflow.example_dags.example_xcomargs)
bash_push (in module airflow.example_dags.example_xcom)
BashOperator (class in airflow.operators.bash)
BashSensor (class in airflow.sensors.bash)
BLUE (airflow.operators.python.PythonOperator attribute)
branch (airflow.decorators.TaskDecoratorCollection attribute)
branch() (in module airflow.example_dags.example_nested_branch_dag)
branch_external_python (airflow.decorators.TaskDecoratorCollection attribute)
branch_external_python_task() (in module airflow.decorators.branch_external_python)
branch_task() (in module airflow.decorators.branch_python)
branch_virtualenv (airflow.decorators.TaskDecoratorCollection attribute)
branch_virtualenv_task() (in module airflow.decorators.branch_virtualenv)
BranchDateTimeOperator (class in airflow.operators.datetime)
BranchDayOfWeekOperator (class in airflow.operators.weekday)
BranchExternalPythonOperator (class in airflow.operators.python)
BranchMixIn (class in airflow.operators.branch)
BranchPythonOperator (class in airflow.operators.python)
BranchPythonVirtualenvOperator (class in airflow.operators.python)
build_path() (airflow.secrets.base_secrets.BaseSecretsBackend static method)
bulk_sync_to_db() (airflow.models.dag.DAG class method)
bulk_write_to_db() (airflow.models.dag.DAG class method)
C
calculate_dagrun_date_fields() (airflow.models.dag.DagModel method)
can_be_scheduled (airflow.timetables.base.Timetable property)
(airflow.timetables.simple.NullTimetable attribute)
catchup (airflow.timetables.base.TimeRestriction attribute)
chain() (in module airflow.models.baseoperator)
chain_linear() (in module airflow.models.baseoperator)
Chainable (in module airflow.models.baseoperator)
changed_tis (airflow.models.dagrun.TISchedulingDecision attribute)
check_and_change_state_before_execution() (airflow.models.taskinstance.TaskInstance method)
check_for_write_conflict() (airflow.models.variable.Variable static method)
child_task1 (in module airflow.example_dags.example_external_task_marker_dag)
choose_branch() (airflow.operators.branch.BaseBranchOperator method)
(airflow.operators.datetime.BranchDateTimeOperator method)
(airflow.operators.latest_only.LatestOnlyOperator method)
(airflow.operators.weekday.BranchDayOfWeekOperator method)
CLASS_IDENTIFIER (airflow.models.param.Param attribute)
cleanup() (airflow.triggers.base.BaseTrigger method)
clear() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.dag.DAG method)
clear_dags() (airflow.models.dag.DAG class method)
clear_next_method_args() (airflow.models.taskinstance.TaskInstance method)
clear_number (airflow.models.dagrun.DagRun attribute)
clear_task_instances() (in module airflow.models.taskinstance)
clear_xcom_data() (airflow.models.taskinstance.TaskInstance method)
cli() (airflow.models.dag.DAG method)
coerce_resources() (in module airflow.models.baseoperator)
coerce_timedelta() (in module airflow.models.baseoperator)
collect_dags() (airflow.models.dagbag.DagBag method)
collect_dags_from_db() (airflow.models.dagbag.DagBag method)
color() (airflow.utils.state.State class method)
color_fg() (airflow.utils.state.State class method)
command_as_list() (airflow.models.taskinstance.TaskInstance method)
concurrency (airflow.models.dag.DAG property)
concurrency_reached (airflow.models.dag.DAG property)
cond (in module airflow.example_dags.example_branch_python_dop_operator_3)
cond1 (in module airflow.example_dags.example_branch_datetime_operator)
cond2 (in module airflow.example_dags.example_branch_datetime_operator)
cond3 (in module airflow.example_dags.example_branch_datetime_operator)
cond_true (in module airflow.example_dags.example_short_circuit_operator)
conf (airflow.models.dagrun.DagRun attribute)
CONN_ENV_PREFIX (in module airflow.secrets.environment_variables)
conn_id (airflow.models.connection.Connection attribute)
conn_name_attr (airflow.hooks.base.DiscoverableHook attribute)
(airflow.hooks.filesystem.FSHook attribute)
(airflow.hooks.package_index.PackageIndexHook attribute)
conn_type (airflow.hooks.base.DiscoverableHook attribute)
(airflow.hooks.filesystem.FSHook attribute)
(airflow.hooks.package_index.PackageIndexHook attribute)
(airflow.models.connection.Connection attribute)
Connection (class in airflow.models.connection)
ConnectionNotUnique
content (airflow.models.dagrun.DagRunNote attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
context_wrapper (in module airflow.decorators.setup_teardown)
ContextWrapper (class in airflow.decorators.setup_teardown)
ContinuousTimetable (class in airflow.timetables.simple)
count_dags() (airflow.triggers.external_task.DagStateTrigger method)
count_running_dags() (airflow.triggers.external_task.TaskStateTrigger method)
count_tasks() (airflow.triggers.external_task.TaskStateTrigger method)
create_dagrun() (airflow.models.dag.DAG method)
create_entry_group (in module airflow.example_dags.example_complex)
create_test_pipeline() (in module airflow.example_dags.example_skip_dag)
create_timetable() (in module airflow.models.dag)
created_at (airflow.models.dagrun.DagRunNote attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
CreatedTasks (in module airflow.models.dagrun)
creating_job_id (airflow.models.dagrun.DagRun attribute)
CronDataIntervalTimetable (class in airflow.timetables.interval)
CronMixin (class in airflow.timetables._cron)
CronTriggerTimetable (class in airflow.timetables.trigger)
cross_downstream() (in module airflow.models.baseoperator)
current_autoregister_module_name (airflow.models.dag.DagContext attribute)
current_state() (airflow.models.taskinstance.TaskInstance method)
custom_operator_name (airflow.decorators.sensor.DecoratedSensorOperator attribute)
(airflow.models.taskinstance.TaskInstance attribute)
D
dag (airflow.models.baseoperator.BaseOperator property)
DAG (class in airflow.models.dag)
dag() (in module airflow.models.dag)
dag1 (in module airflow.example_dags.example_branch_datetime_operator)
dag1_dataset (in module airflow.example_dags.example_datasets)
dag2 (in module airflow.example_dags.example_branch_datetime_operator)
dag2_dataset (in module airflow.example_dags.example_datasets)
dag3 (in module airflow.example_dags.example_branch_datetime_operator)
dag_hash (airflow.models.dagrun.DagRun attribute)
dag_id (airflow.models.dag.DAG property)
(airflow.models.dag.DagModel attribute)
(airflow.models.dag.DagOwnerAttributes attribute)
(airflow.models.dag.DagTag attribute)
(airflow.models.dagrun.DagRun attribute)
(airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
(airflow.models.taskinstancekey.TaskInstanceKey attribute)
(airflow.models.xcom.BaseXCom attribute)
dag_ids (airflow.models.dagbag.DagBag property)
dag_model (airflow.models.dagrun.DagRun attribute)
(airflow.models.taskinstance.TaskInstance attribute)
DAG_NAME (in module airflow.example_dags.example_subdag_operator)
dag_num (airflow.models.dagbag.FileLoadStat attribute)
dag_owner_links (airflow.models.dag.DagModel attribute)
dag_policy() (in module airflow.policies)
dag_run (airflow.models.dagrun.DagRunNote attribute)
(airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.xcom.BaseXCom attribute)
dag_run_id (airflow.models.dagrun.DagRunNote attribute)
(airflow.models.xcom.BaseXCom attribute)
dag_run_note (airflow.models.dagrun.DagRun attribute)
dag_states (airflow.utils.state.State attribute)
DagBag (class in airflow.models.dagbag)
dagbag_report() (airflow.models.dagbag.DagBag method)
DagCodeNotFound
DagConcurrencyLimitReached
DagContext (class in airflow.models.dag)
DagFileExists
DagModel (class in airflow.models.dag)
DagNotFound
DagOwnerAttributes (class in airflow.models.dag)
DagParam (class in airflow.models.param)
DagRun (class in airflow.models.dagrun)
DagRunAlreadyExists
DagRunInfo (class in airflow.timetables.base)
DagRunNote (class in airflow.models.dagrun)
DagRunNotFound
DagRunState (class in airflow.utils.state)
dags (airflow.models.dagbag.FileLoadStat attribute)
dags_needing_dagruns() (airflow.models.dag.DagModel class method)
DagStateChangeCallback (in module airflow.models.dag)
DagStateTrigger (class in airflow.triggers.external_task)
DagTag (class in airflow.models.dag)
data_interval (airflow.timetables.base.DagRunInfo attribute)
data_interval_end (airflow.models.dagrun.DagRun attribute)
data_interval_start (airflow.models.dagrun.DagRun attribute)
DataInterval (class in airflow.timetables.base)
date_range() (airflow.models.dag.DAG method)
datetime_diff_for_humans() (in module airflow.macros)
DateTimeSensor (class in airflow.sensors.date_time)
DateTimeSensorAsync (class in airflow.sensors.date_time)
DateTimeTrigger (class in airflow.triggers.temporal)
DayOfWeekSensor (class in airflow.sensors.weekday)
deactivate_deleted_dags() (airflow.models.dag.DagModel class method)
deactivate_stale_dags() (airflow.models.dag.DAG static method)
deactivate_unknown_dags() (airflow.models.dag.DAG static method)
debug_info() (airflow.models.connection.Connection method)
DecoratedMappedOperator (class in airflow.decorators.base)
DecoratedOperator (class in airflow.decorators.base)
DecoratedSensorOperator (class in airflow.decorators.sensor)
default_conn_name (airflow.hooks.base.DiscoverableHook attribute)
(airflow.hooks.filesystem.FSHook attribute)
(airflow.hooks.package_index.PackageIndexHook attribute)
DEFAULT_DAGRUNS_TO_EXAMINE (airflow.models.dagrun.DagRun attribute)
DEFAULT_SCHEDULE_INTERVAL (in module airflow.models.dag)
DEFAULT_SECRETS_SEARCH_PATH (in module airflow.secrets)
default_view (airflow.models.dag.DAG property)
(airflow.models.dag.DagModel attribute)
DEFAULT_VIEW_PRESETS (in module airflow.models.dag)
defer() (airflow.models.baseoperator.BaseOperator method)
DEFERRED (airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
delete() (airflow.models.variable.Variable static method)
(airflow.models.xcom.BaseXCom class method)
Delta (in module airflow.timetables.interval)
DeltaDataIntervalTimetable (class in airflow.timetables.interval)
deprecated_provider_since (airflow.exceptions.AirflowProviderDeprecationWarning attribute)
deprecated_since (airflow.exceptions.RemovedInAirflow3Warning attribute)
deps (airflow.models.baseoperator.BaseOperator attribute)
(airflow.sensors.base.BaseSensorOperator attribute)
description (airflow.models.connection.Connection attribute)
(airflow.models.dag.DAG property)
(airflow.models.dag.DagModel attribute)
(airflow.models.variable.Variable attribute)
(airflow.timetables.base.Timetable attribute)
(airflow.timetables.simple.ContinuousTimetable attribute)
(airflow.timetables.simple.NullTimetable attribute)
(airflow.timetables.simple.OnceTimetable attribute)
deserialize() (airflow.models.param.Param static method)
(airflow.models.param.ParamsDict static method)
(airflow.timetables.base.Timetable class method)
(airflow.timetables.events.EventsTimetable class method)
(airflow.timetables.interval.CronDataIntervalTimetable class method)
(airflow.timetables.interval.DeltaDataIntervalTimetable class method)
(airflow.timetables.trigger.CronTriggerTimetable class method)
deserialize_connection() (airflow.secrets.base_secrets.BaseSecretsBackend method)
deserialize_value() (airflow.models.xcom.BaseXCom static method)
DeserializingResultError
determine_kwargs() (airflow.operators.python.PythonOperator method)
DiscoverableHook (class in airflow.hooks.base)
do_branch() (airflow.operators.branch.BranchMixIn method)
dry_run() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.taskinstance.TaskInstance method)
ds_add() (in module airflow.macros)
ds_format() (in module airflow.macros)
dump() (airflow.models.param.Param method)
(airflow.models.param.ParamsDict method)
DuplicateTaskIdFound
duration (airflow.models.dagbag.FileLoadStat attribute)
(airflow.models.taskinstance.TaskInstance attribute)
E
earliest (airflow.timetables.base.TimeRestriction attribute)
email_alert() (airflow.models.taskinstance.TaskInstance method)
EmailOperator (class in airflow.operators.email)
emit_state_change_metric() (airflow.models.taskinstance.TaskInstance method)
empty_task_1 (in module airflow.example_dags.example_branch_day_of_week_operator)
empty_task_11 (in module airflow.example_dags.example_branch_datetime_operator)
empty_task_12 (in module airflow.example_dags.example_branch_datetime_operator)
empty_task_13 (in module airflow.example_dags.example_branch_datetime_operator)
empty_task_21 (in module airflow.example_dags.example_branch_datetime_operator)
empty_task_22 (in module airflow.example_dags.example_branch_datetime_operator)
empty_task_23 (in module airflow.example_dags.example_branch_datetime_operator)
EmptyOperator (class in airflow.operators.empty)
EmptySkipOperator (class in airflow.example_dags.example_skip_dag)
end (airflow.timetables.base.DataInterval attribute)
end_date (airflow.models.baseoperator.BaseOperator attribute)
(airflow.models.dagrun.DagRun attribute)
(airflow.models.taskinstance.TaskInstance attribute)
environment variable
AIRFLOW__{SECTION}__{KEY}
,
[1]
,
[2]
AIRFLOW__{SECTION}__{KEY}_CMD
AIRFLOW__{SECTION}__{KEY}_SECRET
AIRFLOW_CONFIG
,
[1]
AIRFLOW_CONN_{CONN_ID}
,
[1]
,
[2]
AIRFLOW_HOME
,
[1]
AIRFLOW_VAR_{KEY}
,
[1]
AIRFLOW_VAR_{VARIABLE_NAME}
FLASK_APP
PYTHONPATH
,
[1]
,
[2]
,
[3]
,
[4]
,
[5]
,
[6]
,
[7]
,
[8]
,
[9]
EnvironmentVariablesBackend (class in airflow.secrets.environment_variables)
error() (airflow.models.taskinstance.TaskInstance method)
EventsTimetable (class in airflow.timetables.events)
exact() (airflow.timetables.base.DagRunInfo class method)
(airflow.timetables.base.DataInterval class method)
example_dag (in module airflow.example_dags.example_short_circuit_decorator)
example_python_decorator() (in module airflow.example_dags.example_python_decorator)
example_sensor_decorator() (in module airflow.example_dags.example_sensor_decorator)
example_short_circuit_decorator() (in module airflow.example_dags.example_short_circuit_decorator)
execute() (airflow.decorators.base.DecoratedOperator method)
(airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.AddOneOperator method)
(airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.SumItOperator method)
(airflow.example_dags.example_skip_dag.EmptySkipOperator method)
(airflow.models.baseoperator.BaseOperator method)
(airflow.operators.bash.BashOperator method)
(airflow.operators.branch.BaseBranchOperator method)
(airflow.operators.email.EmailOperator method)
(airflow.operators.empty.EmptyOperator method)
(airflow.operators.generic_transfer.GenericTransfer method)
(airflow.operators.python.BranchExternalPythonOperator method)
(airflow.operators.python.BranchPythonOperator method)
(airflow.operators.python.BranchPythonVirtualenvOperator method)
(airflow.operators.python.PythonOperator method)
(airflow.operators.python.ShortCircuitOperator method)
(airflow.operators.smooth.SmoothOperator method)
(airflow.operators.trigger_dagrun.TriggerDagRunOperator method)
(airflow.sensors.base.BaseSensorOperator method)
(airflow.sensors.date_time.DateTimeSensorAsync method)
(airflow.sensors.external_task.ExternalTaskSensor method)
(airflow.sensors.time_delta.TimeDeltaSensorAsync method)
(airflow.sensors.time_sensor.TimeSensorAsync method)
execute_callable() (airflow.operators.python.ExternalPythonOperator method)
(airflow.operators.python.PythonOperator method)
(airflow.operators.python.PythonVirtualenvOperator method)
execute_callback() (airflow.models.dag.DAG class method)
execute_complete() (airflow.operators.trigger_dagrun.TriggerDagRunOperator method)
(airflow.sensors.date_time.DateTimeSensorAsync method)
(airflow.sensors.external_task.ExternalTaskSensor method)
(airflow.sensors.time_delta.TimeDeltaSensorAsync method)
(airflow.sensors.time_sensor.TimeSensorAsync method)
execution_date (airflow.models.dagrun.DagRun attribute)
(airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.xcom.BaseXCom attribute)
executor_config (airflow.models.taskinstance.TaskInstance attribute)
expand() (airflow.decorators.base.Task method)
expand_kwargs() (airflow.decorators.base.Task method)
external_executor_id (airflow.models.taskinstance.TaskInstance attribute)
external_python (airflow.decorators.TaskDecoratorCollection attribute)
external_trigger (airflow.models.dagrun.DagRun attribute)
ExternalDagLink (class in airflow.sensors.external_task)
ExternalPythonOperator (class in airflow.operators.python)
ExternalTaskMarker (class in airflow.sensors.external_task)
ExternalTaskSensor (class in airflow.sensors.external_task)
ExternalTaskSensorLink (class in airflow.sensors.external_task)
extra (airflow.models.connection.Connection property)
extra_dejson (airflow.models.connection.Connection property)
EXTRA_KEY (airflow.models.connection.Connection attribute)
extract() (in module airflow.example_dags.tutorial_dag)
F
FAILED (airflow.utils.state.DagRunState attribute)
(airflow.utils.state.JobState attribute)
(airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
failed_states (airflow.utils.state.State attribute)
FailStopDagInvalidTriggerRule
failure_callable() (in module airflow.example_dags.example_sensors)
FailureTrigger (class in airflow.triggers.testing)
Feature releases
fetch_callback() (airflow.models.dag.DAG static method)
fetch_dagrun() (airflow.models.dag.DAG static method)
fetch_handle_failure_context() (airflow.models.taskinstance.TaskInstance class method)
fetch_task_instance() (airflow.models.dagrun.DagRun static method)
fetch_task_instances() (airflow.models.dagrun.DagRun static method)
file (airflow.models.dagbag.FileLoadStat attribute)
FILE_PARSERS (in module airflow.secrets.local_filesystem)
FileLoadStat (class in airflow.models.dagbag)
fileloc (airflow.models.dag.DAG attribute)
(airflow.models.dag.DagModel attribute)
FileSensor (class in airflow.sensors.filesystem)
FileSyntaxError (class in airflow.exceptions)
FileTrigger (class in airflow.triggers.file)
filter_for_tis() (airflow.models.taskinstance.TaskInstance static method)
find() (airflow.models.dagrun.DagRun class method)
find_duplicate() (airflow.models.dagrun.DagRun class method)
finished (airflow.utils.state.State attribute)
finished_dr_states (airflow.utils.state.State attribute)
finished_tis (airflow.models.dagrun.TISchedulingDecision attribute)
FLASK_APP
folder (airflow.models.dag.DAG property)
following_schedule() (airflow.models.dag.DAG method)
FParams (in module airflow.decorators.base)
(in module airflow.decorators.task_group)
FReturn (in module airflow.decorators.base)
(in module airflow.decorators.task_group)
from_dict() (airflow.models.taskinstance.SimpleTaskInstance class method)
from_json() (airflow.models.connection.Connection class method)
from_ti() (airflow.models.taskinstance.SimpleTaskInstance class method)
FSHook (class in airflow.hooks.filesystem)
function (airflow.decorators.base.Task attribute)
G
generate_command() (airflow.models.taskinstance.TaskInstance static method)
generate_run_id() (airflow.models.dagrun.DagRun static method)
(airflow.timetables.base.Timetable method)
generate_value() (in module airflow.example_dags.example_xcomargs)
GenericTransfer (class in airflow.operators.generic_transfer)
get() (airflow.models.variable.Variable class method)
get_active_runs() (airflow.models.dag.DAG method)
get_airflow_context_vars() (in module airflow.policies)
get_all() (airflow.models.dag.DagOwnerAttributes class method)
get_concurrency_reached() (airflow.models.dag.DAG method)
get_config() (airflow.secrets.base_secrets.BaseSecretsBackend method)
get_conn() (airflow.hooks.base.BaseHook method)
(airflow.hooks.filesystem.FSHook method)
(airflow.hooks.package_index.PackageIndexHook method)
get_conn_uri() (airflow.secrets.base_secrets.BaseSecretsBackend method)
(airflow.secrets.environment_variables.EnvironmentVariablesBackend method)
get_conn_value() (airflow.secrets.base_secrets.BaseSecretsBackend method)
(airflow.secrets.environment_variables.EnvironmentVariablesBackend method)
get_connection() (airflow.hooks.base.BaseHook class method)
(airflow.secrets.base_secrets.BaseSecretsBackend method)
(airflow.secrets.local_filesystem.LocalFilesystemBackend method)
(airflow.secrets.metastore.MetastoreBackend method)
get_connection_form_widgets() (airflow.hooks.base.BaseHook class method)
(airflow.hooks.base.DiscoverableHook static method)
(airflow.hooks.filesystem.FSHook static method)
get_connection_from_secrets() (airflow.models.connection.Connection class method)
get_connection_parameter_names() (in module airflow.secrets.local_filesystem)
get_connection_uri() (airflow.secrets.cache.SecretCache class method)
get_connection_url() (airflow.hooks.package_index.PackageIndexHook method)
get_connections() (airflow.hooks.base.BaseHook class method)
(airflow.secrets.base_secrets.BaseSecretsBackend method)
(airflow.secrets.local_filesystem.LocalFilesystemBackend method)
(airflow.secrets.metastore.MetastoreBackend method)
get_count() (airflow.sensors.external_task.ExternalTaskSensor method)
get_current() (airflow.models.dag.DagModel class method)
get_current_context() (in module airflow.operators.python)
get_current_dag() (airflow.models.dag.DagContext class method)
get_dag() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.dagbag.DagBag method)
(airflow.models.dagrun.DagRun method)
get_dagmodel() (airflow.models.dag.DagModel static method)
get_dagrun() (airflow.models.dag.DAG method)
(airflow.models.taskinstance.TaskInstance method)
get_dagruns_between() (airflow.models.dag.DAG method)
get_dataset_triggered_next_run_info() (airflow.models.dag.DagModel method)
(in module airflow.models.dag)
get_default_view() (airflow.models.dag.DAG method)
(airflow.models.dag.DagModel method)
get_direct_relatives() (airflow.models.baseoperator.BaseOperator method)
get_doc_md() (airflow.models.dag.DAG method)
get_edge_info() (airflow.models.dag.DAG method)
get_email_subject_content() (airflow.models.taskinstance.TaskInstance method)
get_env() (airflow.operators.bash.BashOperator method)
get_external_task_group_task_ids() (airflow.sensors.external_task.ExternalTaskSensor method)
get_extra() (airflow.models.connection.Connection method)
get_failed_dep_statuses() (airflow.models.taskinstance.TaskInstance method)
get_hook() (airflow.hooks.base.BaseHook class method)
(airflow.models.connection.Connection method)
get_is_active() (airflow.models.dag.DAG method)
(airflow.models.dag.DagModel method)
get_is_paused() (airflow.models.dag.DAG method)
(airflow.models.dag.DagModel method)
get_last_dagrun() (airflow.models.dag.DAG method)
(airflow.models.dag.DagModel method)
(in module airflow.models.dag)
get_latest_execution_date() (airflow.models.dag.DAG method)
get_latest_runs() (airflow.models.dagrun.DagRun class method)
get_link() (airflow.models.baseoperatorlink.BaseOperatorLink method)
(airflow.operators.trigger_dagrun.TriggerDagRunLink method)
(airflow.sensors.external_task.ExternalDagLink method)
get_log_filename_template() (airflow.models.dagrun.DagRun method)
get_log_template() (airflow.models.dagrun.DagRun method)
get_merged_defaults() (in module airflow.models.baseoperator)
get_names() (in module airflow.example_dags.example_params_trigger_ui)
get_next_workday() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method)
get_num_active_runs() (airflow.models.dag.DAG method)
get_num_running_task_instances() (airflow.models.taskinstance.TaskInstance method)
get_num_task_instances() (airflow.models.dag.DAG static method)
get_param() (airflow.models.param.ParamsDict method)
get_password() (airflow.models.connection.Connection method)
get_path() (airflow.hooks.filesystem.FSHook method)
get_paused_dag_ids() (airflow.models.dag.DagModel static method)
get_previous_dagrun() (airflow.models.dagrun.DagRun static method)
(airflow.models.taskinstance.TaskInstance method)
get_previous_execution_date() (airflow.models.taskinstance.TaskInstance method)
get_previous_scheduled_dagrun() (airflow.models.dagrun.DagRun static method)
get_previous_start_date() (airflow.models.taskinstance.TaskInstance method)
get_previous_ti() (airflow.models.taskinstance.TaskInstance method)
get_python_source() (airflow.decorators.base.DecoratedOperator method)
get_relevant_upstream_map_indexes() (airflow.models.taskinstance.TaskInstance method)
get_rendered_k8s_spec() (airflow.models.taskinstance.TaskInstance method)
get_rendered_template_fields() (airflow.models.taskinstance.TaskInstance method)
get_run_dates() (airflow.models.dag.DAG method)
get_serialized_fields() (airflow.models.baseoperator.BaseOperator class method)
(airflow.models.dag.DAG class method)
(airflow.sensors.base.BaseSensorOperator class method)
(airflow.sensors.external_task.ExternalTaskMarker class method)
get_state() (airflow.models.dagrun.DagRun method)
get_task() (airflow.models.dag.DAG method)
get_task_instance() (airflow.models.dagrun.DagRun method)
(airflow.models.taskinstance.TaskInstance class method)
get_task_instances() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.dag.DAG method)
(airflow.models.dagrun.DagRun method)
get_task_instances_before() (airflow.models.dag.DAG method)
get_template_context() (airflow.models.taskinstance.TaskInstance method)
get_template_env() (airflow.models.dag.DAG method)
get_ui_field_behaviour() (airflow.hooks.base.BaseHook class method)
(airflow.hooks.base.DiscoverableHook static method)
(airflow.hooks.filesystem.FSHook static method)
(airflow.hooks.package_index.PackageIndexHook static method)
get_unique_task_id() (in module airflow.decorators.base)
get_uri() (airflow.models.connection.Connection method)
get_val() (airflow.models.variable.Variable method)
get_value() (airflow.models.xcom.BaseXCom static method)
get_variable() (airflow.secrets.base_secrets.BaseSecretsBackend method)
(airflow.secrets.cache.SecretCache class method)
(airflow.secrets.environment_variables.EnvironmentVariablesBackend method)
(airflow.secrets.local_filesystem.LocalFilesystemBackend method)
(airflow.secrets.metastore.MetastoreBackend method)
get_variable_from_secrets() (airflow.models.variable.Variable static method)
H
handle_callback() (airflow.models.dag.DAG method)
handle_failure() (airflow.models.taskinstance.TaskInstance method)
has_dag() (airflow.models.baseoperator.BaseOperator method)
has_dag_runs() (airflow.models.dag.DAG method)
has_import_errors (airflow.models.dag.DagModel attribute)
has_task() (airflow.models.dag.DAG method)
has_task_concurrency_limits (airflow.models.dag.DagModel attribute)
has_task_group() (airflow.models.dag.DAG method)
has_value (airflow.models.param.Param property)
holiday_calendar (in module airflow.example_dags.plugins.workday)
hook_name (airflow.hooks.base.DiscoverableHook attribute)
(airflow.hooks.filesystem.FSHook attribute)
(airflow.hooks.package_index.PackageIndexHook attribute)
host (airflow.models.connection.Connection attribute)
hostname (airflow.models.taskinstance.TaskInstance attribute)
hybrid_property (in module airflow.models.taskinstance)
I
id (airflow.models.connection.Connection attribute)
(airflow.models.dagrun.DagRun attribute)
(airflow.models.variable.Variable attribute)
InconsistentDataInterval
infer_manual_data_interval() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method)
(airflow.timetables.base.Timetable method)
(airflow.timetables.events.EventsTimetable method)
(airflow.timetables.interval.CronDataIntervalTimetable method)
(airflow.timetables.interval.DeltaDataIntervalTimetable method)
(airflow.timetables.trigger.CronTriggerTimetable method)
ingest (in module airflow.example_dags.example_branch_labels)
inherits_from_empty_operator (airflow.models.baseoperator.BaseOperator property)
(airflow.operators.empty.EmptyOperator attribute)
init() (airflow.secrets.cache.SecretCache class method)
init_on_load() (airflow.models.taskinstance.TaskInstance method)
(airflow.models.xcom.BaseXCom method)
init_run_context() (airflow.models.taskinstance.TaskInstance method)
interval() (airflow.timetables.base.DagRunInfo class method)
invalidate_variable() (airflow.secrets.cache.SecretCache class method)
InvalidStatsNameException
is_active (airflow.models.dag.DagModel attribute)
is_backfill (airflow.models.dagrun.DagRun property)
is_eligible_to_retry() (airflow.models.taskinstance.TaskInstance method)
is_encrypted (airflow.models.connection.Connection attribute)
(airflow.models.variable.Variable attribute)
is_extra_encrypted (airflow.models.connection.Connection attribute)
is_fixed_time_schedule() (airflow.models.dag.DAG method)
is_paused (airflow.models.dag.DAG property)
(airflow.models.dag.DagModel attribute)
is_paused_at_creation (airflow.models.dag.DagModel attribute)
is_premature (airflow.models.taskinstance.TaskInstance property)
is_subdag (airflow.models.dag.DAG property)
(airflow.models.dag.DagModel attribute)
is_venv_installed() (in module airflow.operators.python)
items() (airflow.models.param.ParamsDict method)
iter_dagrun_infos_between() (airflow.models.dag.DAG method)
iter_invalid_owner_links() (airflow.models.dag.DAG method)
J
job_id (airflow.models.taskinstance.TaskInstance attribute)
JobState (class in airflow.utils.state)
K
k8s (in module airflow.example_dags.example_kubernetes_executor)
(in module airflow.example_dags.example_local_kubernetes_executor)
key (airflow.models.taskinstance.TaskInstance property)
(airflow.models.taskinstancekey.TaskInstanceKey property)
(airflow.models.variable.Variable attribute)
(airflow.models.xcom.BaseXCom attribute)
L
last_expired (airflow.models.dag.DagModel attribute)
last_parsed_time (airflow.models.dag.DagModel attribute)
last_pickled (airflow.models.dag.DagModel attribute)
last_scheduling_decision (airflow.models.dagrun.DagRun attribute)
latest (airflow.timetables.base.TimeRestriction attribute)
latest_execution_date (airflow.models.dag.DAG property)
latest_only (in module airflow.example_dags.example_latest_only)
(in module airflow.example_dags.example_latest_only_with_trigger)
LatestOnlyOperator (class in airflow.operators.latest_only)
leaves (airflow.models.baseoperator.BaseOperator property)
(airflow.models.dag.DAG property)
line_no (airflow.exceptions.FileSyntaxError attribute)
link (airflow.models.dag.DagOwnerAttributes attribute)
listeners (airflow.example_dags.plugins.listener_plugin.MetadataCollectionPlugin attribute)
load_connections() (in module airflow.secrets.local_filesystem)
load_connections_dict() (in module airflow.secrets.local_filesystem)
load_variables() (in module airflow.secrets.local_filesystem)
LocalFilesystemBackend (class in airflow.secrets.local_filesystem)
log (in module airflow.example_dags.example_kubernetes_executor)
(in module airflow.example_dags.example_local_kubernetes_executor)
(in module airflow.example_dags.example_python_decorator)
(in module airflow.example_dags.example_python_operator)
(in module airflow.example_dags.example_xcomargs)
(in module airflow.example_dags.plugins.workday)
(in module airflow.example_dags.tutorial_taskflow_api_virtualenv)
(in module airflow.hooks.base)
(in module airflow.models.connection)
(in module airflow.models.dag)
(in module airflow.models.taskinstance)
(in module airflow.models.variable)
(in module airflow.models.xcom)
(in module airflow.secrets.local_filesystem)
log_info() (airflow.models.connection.Connection method)
log_template_id (airflow.models.dagrun.DagRun attribute)
log_url (airflow.models.taskinstance.TaskInstance property)
logger (in module airflow.models.baseoperator)
(in module airflow.models.param)
logical_date (airflow.models.dagrun.DagRun property)
(airflow.timetables.base.DagRunInfo property)
login (airflow.models.connection.Connection attribute)
M
Major release
map_index (airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
(airflow.models.taskinstancekey.TaskInstanceKey attribute)
(airflow.models.xcom.BaseXCom attribute)
mark_success_url (airflow.models.taskinstance.TaskInstance property)
max_active_runs (airflow.models.dag.DagModel attribute)
max_active_tasks (airflow.models.dag.DAG property)
(airflow.models.dag.DagModel attribute)
max_tries (airflow.models.taskinstance.TaskInstance attribute)
message (airflow.exceptions.FileSyntaxError attribute)
MetadataCollectionPlugin (class in airflow.example_dags.plugins.listener_plugin)
MetastoreBackend (class in airflow.secrets.metastore)
module
airflow.decorators
airflow.decorators.base
airflow.decorators.branch_external_python
airflow.decorators.branch_python
airflow.decorators.branch_virtualenv
airflow.decorators.external_python
airflow.decorators.python
airflow.decorators.python_virtualenv
airflow.decorators.sensor
airflow.decorators.setup_teardown
airflow.decorators.short_circuit
airflow.decorators.task_group
airflow.example_dags
airflow.example_dags.example_bash_operator
airflow.example_dags.example_branch_datetime_operator
airflow.example_dags.example_branch_day_of_week_operator
airflow.example_dags.example_branch_labels
airflow.example_dags.example_branch_operator
airflow.example_dags.example_branch_operator_decorator
airflow.example_dags.example_branch_python_dop_operator_3
airflow.example_dags.example_complex
airflow.example_dags.example_datasets
airflow.example_dags.example_dynamic_task_mapping
airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators
airflow.example_dags.example_external_task_marker_dag
airflow.example_dags.example_kubernetes_executor
airflow.example_dags.example_latest_only
airflow.example_dags.example_latest_only_with_trigger
airflow.example_dags.example_local_kubernetes_executor
airflow.example_dags.example_nested_branch_dag
airflow.example_dags.example_params_trigger_ui
airflow.example_dags.example_params_ui_tutorial
airflow.example_dags.example_passing_params_via_test_command
airflow.example_dags.example_python_decorator
airflow.example_dags.example_python_operator
airflow.example_dags.example_sensor_decorator
airflow.example_dags.example_sensors
airflow.example_dags.example_setup_teardown
airflow.example_dags.example_setup_teardown_taskflow
airflow.example_dags.example_short_circuit_decorator
airflow.example_dags.example_short_circuit_operator
airflow.example_dags.example_skip_dag
airflow.example_dags.example_subdag_operator
airflow.example_dags.example_task_group
airflow.example_dags.example_task_group_decorator
airflow.example_dags.example_time_delta_sensor_async
airflow.example_dags.example_trigger_controller_dag
airflow.example_dags.example_trigger_target_dag
airflow.example_dags.example_xcom
airflow.example_dags.example_xcomargs
airflow.example_dags.libs
airflow.example_dags.libs.helper
airflow.example_dags.plugins
airflow.example_dags.plugins.event_listener
airflow.example_dags.plugins.listener_plugin
airflow.example_dags.plugins.workday
airflow.example_dags.subdags
airflow.example_dags.subdags.subdag
airflow.example_dags.tutorial
airflow.example_dags.tutorial_dag
airflow.example_dags.tutorial_objectstorage
airflow.example_dags.tutorial_taskflow_api
airflow.example_dags.tutorial_taskflow_api_virtualenv
airflow.exceptions
airflow.hooks
airflow.hooks.base
airflow.hooks.dbapi
airflow.hooks.filesystem
airflow.hooks.package_index
airflow.hooks.subprocess
airflow.macros
airflow.models.baseoperator
airflow.models.baseoperatorlink
airflow.models.connection
airflow.models.dag
airflow.models.dagbag
airflow.models.dagrun
airflow.models.param
airflow.models.taskinstance
airflow.models.taskinstancekey
airflow.models.variable
airflow.models.xcom
airflow.operators
airflow.operators.bash
airflow.operators.branch
airflow.operators.datetime
airflow.operators.email
airflow.operators.empty
airflow.operators.generic_transfer
airflow.operators.latest_only
airflow.operators.python
airflow.operators.smooth
airflow.operators.subdag
airflow.operators.trigger_dagrun
airflow.operators.weekday
airflow.policies
airflow.secrets
airflow.secrets.base_secrets
airflow.secrets.cache
airflow.secrets.environment_variables
airflow.secrets.local_filesystem
airflow.secrets.metastore
airflow.sensors
airflow.sensors.base
airflow.sensors.bash
airflow.sensors.date_time
airflow.sensors.external_task
airflow.sensors.filesystem
airflow.sensors.python
airflow.sensors.time_delta
airflow.sensors.time_sensor
airflow.sensors.weekday
airflow.timetables
airflow.timetables._cron
airflow.timetables.base
airflow.timetables.events
airflow.timetables.interval
airflow.timetables.simple
airflow.timetables.trigger
airflow.triggers
airflow.triggers.base
airflow.triggers.external_task
airflow.triggers.file
airflow.triggers.temporal
airflow.triggers.testing
airflow.utils.state
multiple_outputs (airflow.decorators.base.DecoratedMappedOperator attribute)
my_first_task() (in module airflow.example_dags.example_setup_teardown_taskflow)
my_py_command() (in module airflow.example_dags.example_passing_params_via_test_command)
N
name (airflow.example_dags.plugins.listener_plugin.MetadataCollectionPlugin attribute)
(airflow.example_dags.plugins.workday.WorkdayTimetablePlugin attribute)
(airflow.models.baseoperatorlink.BaseOperatorLink property)
(airflow.models.dag.DagTag attribute)
(airflow.operators.trigger_dagrun.TriggerDagRunLink attribute)
(airflow.sensors.external_task.ExternalDagLink attribute)
next_dagrun (airflow.models.dag.DagModel attribute)
next_dagrun_after_date() (airflow.models.dag.DAG method)
next_dagrun_create_after (airflow.models.dag.DagModel attribute)
next_dagrun_data_interval (airflow.models.dag.DagModel property)
next_dagrun_data_interval_end (airflow.models.dag.DagModel attribute)
next_dagrun_data_interval_start (airflow.models.dag.DagModel attribute)
next_dagrun_info() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method)
(airflow.models.dag.DAG method)
(airflow.timetables.base.Timetable method)
(airflow.timetables.events.EventsTimetable method)
(airflow.timetables.simple.ContinuousTimetable method)
(airflow.timetables.simple.NullTimetable method)
(airflow.timetables.simple.OnceTimetable method)
(airflow.timetables.trigger.CronTriggerTimetable method)
next_dagruns_to_examine() (airflow.models.dagrun.DagRun class method)
next_kwargs (airflow.models.taskinstance.TaskInstance attribute)
next_method (airflow.models.taskinstance.TaskInstance attribute)
next_retry_datetime() (airflow.models.taskinstance.TaskInstance method)
next_try_number (airflow.models.taskinstance.TaskInstance property)
NoAvailablePoolSlot
NONE (airflow.utils.state.State attribute)
normalize_schedule() (airflow.models.dag.DAG method)
normalized_schedule_interval (airflow.models.dag.DAG property)
note (airflow.models.dagrun.DagRun attribute)
(airflow.models.taskinstance.TaskInstance attribute)
notify_dagrun_state_changed() (airflow.models.dagrun.DagRun method)
NullTimetable (class in airflow.timetables.simple)
NUM_DAGS_PER_DAGRUN_QUERY (airflow.models.dag.DagModel attribute)
O
on_dag_run_failed() (in module airflow.example_dags.plugins.event_listener)
on_dag_run_running() (in module airflow.example_dags.plugins.event_listener)
on_dag_run_success() (in module airflow.example_dags.plugins.event_listener)
on_db_load() (airflow.models.connection.Connection method)
(airflow.models.variable.Variable method)
on_kill() (airflow.models.baseoperator.BaseOperator method)
(airflow.operators.bash.BashOperator method)
on_task_instance_failed() (in module airflow.example_dags.plugins.event_listener)
on_task_instance_running() (in module airflow.example_dags.plugins.event_listener)
on_task_instance_success() (in module airflow.example_dags.plugins.event_listener)
OnceTimetable (class in airflow.timetables.simple)
op_kwargs_expand_input (airflow.decorators.base.DecoratedMappedOperator attribute)
operator (airflow.models.taskinstance.TaskInstance attribute)
operator_class (airflow.models.baseoperator.BaseOperator property)
operator_extra_links (airflow.models.baseoperator.BaseOperator attribute)
(airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute)
(airflow.sensors.external_task.ExternalTaskMarker attribute)
(airflow.sensors.external_task.ExternalTaskSensor attribute)
operator_name (airflow.models.baseoperator.BaseOperator property)
(airflow.models.taskinstance.TaskInstance property)
operators (airflow.models.baseoperatorlink.BaseOperatorLink attribute)
OperatorSubclass (in module airflow.decorators.base)
ORIENTATION_PRESETS (in module airflow.models.dag)
orm_deserialize_value() (airflow.models.xcom.BaseXCom method)
output (airflow.models.baseoperator.BaseOperator property)
override() (airflow.decorators.base.Task method)
(airflow.decorators.base.TaskDecorator method)
overwrite_params_with_dag_run_conf() (airflow.models.taskinstance.TaskInstance method)
owner (airflow.models.dag.DAG property)
(airflow.models.dag.DagOwnerAttributes attribute)
owners (airflow.models.dag.DagModel attribute)
P
PackageIndexHook (class in airflow.hooks.package_index)
Param (class in airflow.models.param)
param() (airflow.models.dag.DAG method)
ParamsDict (class in airflow.models.param)
ParamValidationError
parent_dag (airflow.models.dag.DAG attribute)
(airflow.models.dag.DagModel attribute)
parent_task (in module airflow.example_dags.example_external_task_marker_dag)
parse_from_uri() (airflow.models.connection.Connection method)
parse_netloc_to_hostname() (in module airflow.models.connection)
parse_retries() (in module airflow.models.baseoperator)
partial (airflow.models.baseoperator.BaseOperator attribute)
partial() (airflow.decorators.base.Task method)
(in module airflow.models.baseoperator)
partial_subset() (airflow.models.dag.DAG method)
password (airflow.models.connection.Connection property)
PAST_DEPENDS_MET (in module airflow.models.taskinstance)
Patch releases
PATH_TO_PYTHON_BINARY (in module airflow.example_dags.example_branch_operator)
(in module airflow.example_dags.example_branch_operator_decorator)
(in module airflow.example_dags.example_python_decorator)
(in module airflow.example_dags.example_python_operator)
periodic (airflow.timetables.base.Timetable attribute)
pickle() (airflow.models.dag.DAG method)
pickle_id (airflow.models.dag.DAG property)
(airflow.models.dag.DagModel attribute)
pickle_info() (airflow.models.dag.DAG method)
pid (airflow.models.taskinstance.TaskInstance attribute)
pod_mutation_hook() (in module airflow.policies)
PodMutationHookException
PodReconciliationError
poke() (airflow.operators.subdag.SubDagOperator method)
(airflow.sensors.base.BaseSensorOperator method)
(airflow.sensors.bash.BashSensor method)
(airflow.sensors.date_time.DateTimeSensor method)
(airflow.sensors.external_task.ExternalTaskSensor method)
(airflow.sensors.filesystem.FileSensor method)
(airflow.sensors.python.PythonSensor method)
(airflow.sensors.time_delta.TimeDeltaSensor method)
(airflow.sensors.time_sensor.TimeSensor method)
(airflow.sensors.weekday.DayOfWeekSensor method)
poke_mode_only() (in module airflow.sensors.base)
PokeReturnValue (class in airflow.sensors.base)
pool (airflow.models.baseoperator.BaseOperator attribute)
(airflow.models.taskinstance.TaskInstance attribute)
pool_slots (airflow.models.taskinstance.TaskInstance attribute)
PoolNotFound
pop_context_managed_dag() (airflow.models.dag.DagContext class method)
port (airflow.models.connection.Connection attribute)
post_execute() (airflow.models.baseoperator.BaseOperator method)
(airflow.operators.subdag.SubDagOperator method)
pre_execute() (airflow.models.baseoperator.BaseOperator method)
(airflow.operators.subdag.SubDagOperator method)
prepare_for_execution() (airflow.models.baseoperator.BaseOperator method)
(airflow.sensors.base.BaseSensorOperator method)
prev_attempted_tries (airflow.models.taskinstance.TaskInstance property)
previous_schedule() (airflow.models.dag.DAG method)
previous_start_date_success (airflow.models.taskinstance.TaskInstance property)
previous_ti (airflow.models.taskinstance.TaskInstance property)
previous_ti_success (airflow.models.taskinstance.TaskInstance property)
primary (airflow.models.taskinstancekey.TaskInstanceKey property)
print_context() (in module airflow.example_dags.example_python_operator)
print_env_vars() (in module airflow.example_dags.example_passing_params_via_test_command)
print_stuff() (in module airflow.example_dags.libs.helper)
print_value() (in module airflow.example_dags.example_xcomargs)
priority_weight (airflow.models.taskinstance.TaskInstance attribute)
process_file() (airflow.models.dagbag.DagBag method)
process_params() (in module airflow.models.param)
processor_subdir (airflow.models.dag.DagModel attribute)
pull_value_from_bash_push() (in module airflow.example_dags.example_xcom)
puller() (in module airflow.example_dags.example_xcom)
push() (in module airflow.example_dags.example_xcom)
push_by_returning() (in module airflow.example_dags.example_xcom)
push_context_managed_dag() (airflow.models.dag.DagContext class method)
python (airflow.decorators.TaskDecoratorCollection attribute)
python_callable (airflow.decorators.base.DecoratedMappedOperator attribute)
python_task() (in module airflow.decorators.python)
PythonOperator (class in airflow.operators.python)
PYTHONPATH
,
[1]
,
[2]
,
[3]
,
[4]
,
[5]
,
[6]
,
[7]
,
[8]
,
[9]
PythonSensor (class in airflow.sensors.python)
PythonVirtualenvOperator (class in airflow.operators.python)
Q
queue (airflow.models.taskinstance.TaskInstance attribute)
QUEUED (airflow.utils.state.DagRunState attribute)
(airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
queued_at (airflow.models.dagrun.DagRun attribute)
queued_by_job_id (airflow.models.taskinstance.TaskInstance attribute)
queued_dttm (airflow.models.taskinstance.TaskInstance attribute)
R
random() (in module airflow.macros)
ready_for_retry() (airflow.models.taskinstance.TaskInstance method)
reduced (airflow.models.taskinstancekey.TaskInstanceKey property)
refresh_from_db() (airflow.models.dagrun.DagRun method)
(airflow.models.taskinstance.TaskInstance method)
refresh_from_task() (airflow.models.taskinstance.TaskInstance method)
relative_fileloc (airflow.models.dag.DAG property)
(airflow.models.dag.DagModel property)
REMOVED (airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
RemovedInAirflow3Warning
render_k8s_pod_yaml() (airflow.models.taskinstance.TaskInstance method)
render_template_fields() (airflow.models.baseoperator.BaseOperator method)
render_templates() (airflow.models.taskinstance.TaskInstance method)
rendered_task_instance_fields (airflow.models.taskinstance.TaskInstance attribute)
reschedule (airflow.sensors.base.BaseSensorOperator property)
reset() (airflow.secrets.cache.SecretCache class method)
resolve() (airflow.models.param.DagParam method)
(airflow.models.param.Param method)
resolve_template_files() (airflow.models.dag.DAG method)
resolve_xcom_backend() (in module airflow.models.xcom)
RESTARTING (airflow.utils.state.JobState attribute)
(airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
resume_execution() (airflow.models.baseoperator.BaseOperator method)
(airflow.sensors.base.BaseSensorOperator method)
root_dag_id (airflow.models.dag.DagModel attribute)
root_setup (in module airflow.example_dags.example_setup_teardown)
roots (airflow.models.baseoperator.BaseOperator property)
(airflow.models.dag.DAG property)
rotate_fernet_key() (airflow.models.connection.Connection method)
(airflow.models.variable.Variable method)
run() (airflow.models.baseoperator.BaseOperator method)
(airflow.models.dag.DAG method)
(airflow.models.taskinstance.TaskInstance method)
(airflow.triggers.base.BaseTrigger method)
(airflow.triggers.external_task.DagStateTrigger method)
(airflow.triggers.external_task.TaskStateTrigger method)
(airflow.triggers.file.FileTrigger method)
(airflow.triggers.temporal.DateTimeTrigger method)
(airflow.triggers.testing.FailureTrigger method)
(airflow.triggers.testing.SuccessTrigger method)
run_after (airflow.timetables.base.DagRunInfo attribute)
run_command() (airflow.hooks.subprocess.SubprocessHook method)
run_id (airflow.models.dagrun.DagRun attribute)
(airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
(airflow.models.taskinstancekey.TaskInstanceKey attribute)
(airflow.models.xcom.BaseXCom attribute)
RUN_ID_REGEX (in module airflow.models.dagrun)
run_ordering (airflow.timetables.base.Timetable attribute)
run_this (in module airflow.example_dags.example_passing_params_via_test_command)
(in module airflow.example_dags.example_trigger_target_dag)
run_this_first (in module airflow.example_dags.example_branch_operator)
(in module airflow.example_dags.example_branch_operator_decorator)
run_this_func() (in module airflow.example_dags.example_trigger_target_dag)
run_this_last (in module airflow.example_dags.example_bash_operator)
run_type (airflow.models.dagrun.DagRun attribute)
RUNNING (airflow.utils.state.DagRunState attribute)
(airflow.utils.state.JobState attribute)
(airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
S
safe_dag_id (airflow.models.dag.DagModel property)
save_connection_uri() (airflow.secrets.cache.SecretCache class method)
save_to_db() (airflow.models.taskinstance.TaskInstance static method)
save_variable() (airflow.secrets.cache.SecretCache class method)
schedulable_tis (airflow.models.dagrun.TISchedulingDecision attribute)
schedule_dataset_references (airflow.models.dag.DagModel attribute)
schedule_datasets (airflow.models.dag.DagModel attribute)
schedule_downstream_tasks() (airflow.models.taskinstance.TaskInstance method)
schedule_interval (airflow.models.dag.DagModel attribute)
schedule_tis() (airflow.models.dagrun.DagRun method)
ScheduleArg (in module airflow.models.dag)
SCHEDULED (airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
ScheduleInterval (in module airflow.models.baseoperator)
(in module airflow.models.dag)
ScheduleIntervalArg (in module airflow.models.dag)
scheduler_lock (airflow.models.dag.DagModel attribute)
schema (airflow.models.connection.Connection attribute)
SecretCache (class in airflow.secrets.cache)
send_sigterm() (airflow.hooks.subprocess.SubprocessHook method)
sensor (airflow.decorators.TaskDecoratorCollection attribute)
sensor_task() (in module airflow.decorators.sensor)
SerializationError
serialize() (airflow.models.param.Param method)
(airflow.models.param.ParamsDict method)
(airflow.timetables.base.Timetable method)
(airflow.timetables.events.EventsTimetable method)
(airflow.timetables.interval.CronDataIntervalTimetable method)
(airflow.timetables.interval.DeltaDataIntervalTimetable method)
(airflow.timetables.trigger.CronTriggerTimetable method)
(airflow.triggers.base.BaseTrigger method)
(airflow.triggers.external_task.DagStateTrigger method)
(airflow.triggers.external_task.TaskStateTrigger method)
(airflow.triggers.file.FileTrigger method)
(airflow.triggers.temporal.DateTimeTrigger method)
(airflow.triggers.testing.FailureTrigger method)
(airflow.triggers.testing.SuccessTrigger method)
serialize_for_task_group() (airflow.models.baseoperator.BaseOperator method)
serialize_value() (airflow.models.xcom.BaseXCom static method)
set() (airflow.models.variable.Variable static method)
set_current_context() (in module airflow.models.taskinstance)
set_dag_runs_state() (airflow.models.dag.DAG method)
set_dependency() (airflow.models.dag.DAG method)
set_duration() (airflow.models.taskinstance.TaskInstance method)
set_edge_info() (airflow.models.dag.DAG method)
set_extra() (airflow.models.connection.Connection method)
set_is_paused() (airflow.models.dag.DagModel method)
set_password() (airflow.models.connection.Connection method)
set_state() (airflow.models.dagrun.DagRun method)
(airflow.models.taskinstance.TaskInstance method)
set_task_group_state() (airflow.models.dag.DAG method)
set_task_instance_state() (airflow.models.dag.DAG method)
set_val() (airflow.models.variable.Variable method)
set_xcomargs_dependencies() (airflow.models.baseoperator.BaseOperator method)
setdefault() (airflow.models.variable.Variable class method)
setup (in module airflow.decorators)
setup_task() (in module airflow.decorators.setup_teardown)
shallow_copy_attrs (airflow.decorators.base.DecoratedOperator attribute)
(airflow.decorators.sensor.DecoratedSensorOperator attribute)
(airflow.models.baseoperator.BaseOperator attribute)
(airflow.operators.python.PythonOperator attribute)
short_circuit (airflow.decorators.TaskDecoratorCollection attribute)
ShortCircuitOperator (class in airflow.operators.python)
should_run() (in module airflow.example_dags.example_branch_python_dop_operator_3)
show_params() (in module airflow.example_dags.example_params_ui_tutorial)
SimpleTaskInstance (class in airflow.models.taskinstance)
size() (airflow.models.dagbag.DagBag method)
SKIPPED (airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
SkippedStatePropagationOptions (class in airflow.operators.subdag)
SLAMissCallback (in module airflow.models.dag)
SmoothOperator (class in airflow.operators.smooth)
start (airflow.timetables.base.DataInterval attribute)
(in module airflow.example_dags.example_subdag_operator)
(in module airflow.example_dags.example_task_group)
start_date (airflow.models.baseoperator.BaseOperator attribute)
(airflow.models.dagrun.DagRun attribute)
(airflow.models.taskinstance.TaskInstance attribute)
(in module airflow.example_dags.example_external_task_marker_dag)
start_task (in module airflow.example_dags.example_task_group_decorator)
start_task_executor_config (in module airflow.example_dags.example_kubernetes_executor)
(in module airflow.example_dags.example_local_kubernetes_executor)
state (airflow.models.dagrun.DagRun property)
(airflow.models.taskinstance.TaskInstance attribute)
State (class in airflow.utils.state)
state_color (airflow.utils.state.State attribute)
stats_tags (airflow.models.dagrun.DagRun property)
(airflow.models.taskinstance.TaskInstance property)
status_code (airflow.exceptions.AirflowBadRequest attribute)
(airflow.exceptions.AirflowException attribute)
(airflow.exceptions.AirflowNotFoundException attribute)
store_serialized_dags (airflow.models.dagbag.DagBag property)
sub_dag() (airflow.models.dag.DAG method)
subdag (airflow.models.baseoperator.BaseOperator attribute)
(airflow.operators.subdag.SubDagOperator attribute)
subdag() (in module airflow.example_dags.subdags.subdag)
SubDagOperator (class in airflow.operators.subdag)
subdags (airflow.models.dag.DAG property)
subprocess_hook() (airflow.operators.bash.BashOperator method)
SubprocessHook (class in airflow.hooks.subprocess)
SubprocessResult (in module airflow.hooks.subprocess)
SUCCESS (airflow.utils.state.DagRunState attribute)
(airflow.utils.state.JobState attribute)
(airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
success_callable() (in module airflow.example_dags.example_sensors)
success_states (airflow.utils.state.State attribute)
SuccessTrigger (class in airflow.triggers.testing)
SumItOperator (class in airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators)
summary (airflow.timetables._cron.CronMixin property)
(airflow.timetables.base.Timetable property)
(airflow.timetables.events.EventsTimetable property)
(airflow.timetables.interval.DeltaDataIntervalTimetable property)
(airflow.timetables.simple.ContinuousTimetable property)
(airflow.timetables.simple.NullTimetable property)
(airflow.timetables.simple.OnceTimetable property)
supports_lineage (airflow.models.baseoperator.BaseOperator attribute)
sync_to_db() (airflow.models.dag.DAG method)
(airflow.models.dagbag.DagBag method)
T
T (in module airflow.models.baseoperator)
t0 (in module airflow.example_dags.example_sensors)
t1 (in module airflow.example_dags.tutorial)
TAG_MAX_LEN (in module airflow.models.dag)
tags (airflow.models.dag.DagModel attribute)
target_times_as_dates() (in module airflow.operators.datetime)
task (airflow.models.dag.DAG property)
(airflow.models.taskinstance.TaskInstance attribute)
Task (class in airflow.decorators.base)
task (in module airflow.decorators)
task() (in module airflow.operators.python)
task_1() (in module airflow.example_dags.example_task_group_decorator)
task_2() (in module airflow.example_dags.example_task_group_decorator)
task_3() (in module airflow.example_dags.example_task_group_decorator)
task_decorator_factory() (in module airflow.decorators.base)
task_end() (in module airflow.example_dags.example_task_group_decorator)
task_group (airflow.models.baseoperator.BaseOperator attribute)
(airflow.models.dag.DAG property)
task_group() (in module airflow.decorators.task_group)
task_group_dict() (airflow.models.dag.DAG method)
task_group_function() (in module airflow.example_dags.example_task_group_decorator)
task_group_sig (in module airflow.decorators.task_group)
task_id (airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
(airflow.models.taskinstancekey.TaskInstanceKey attribute)
(airflow.models.xcom.BaseXCom attribute)
task_ids (airflow.models.dag.DAG property)
task_instance (airflow.models.taskinstance.TaskInstanceNote attribute)
task_instance_mutation_hook() (in module airflow.policies)
task_instance_note (airflow.models.taskinstance.TaskInstance attribute)
task_instance_scheduling_decisions() (airflow.models.dagrun.DagRun method)
task_instances (airflow.models.dagrun.DagRun attribute)
task_num (airflow.models.dagbag.FileLoadStat attribute)
task_outlet_dataset_references (airflow.models.dag.DagModel attribute)
task_policy() (in module airflow.policies)
task_start() (in module airflow.example_dags.example_task_group_decorator)
task_states (airflow.utils.state.State attribute)
task_type (airflow.models.baseoperator.BaseOperator property)
TaskAlreadyInTaskGroup
TaskConcurrencyLimitReached
TaskDecorator (class in airflow.decorators.base)
TaskDecoratorCollection (class in airflow.decorators)
TaskDeferralError
TaskDeferred
TaskInstance (class in airflow.models.taskinstance)
TaskInstanceKey (class in airflow.models.taskinstancekey)
TaskInstanceNote (class in airflow.models.taskinstance)
TaskInstanceNotFound
TaskInstanceState (class in airflow.utils.state)
TaskInstanceStateType (in module airflow.models.taskinstance)
TaskNotFound
TaskPostExecuteHook (in module airflow.models.baseoperator)
TaskPreExecuteHook (in module airflow.models.baseoperator)
tasks (airflow.models.dag.DAG property)
tasks_upstream_of_teardowns (airflow.models.dag.DAG property)
TaskStateTrigger (class in airflow.triggers.external_task)
teardown (in module airflow.decorators)
teardown_task() (in module airflow.decorators.setup_teardown)
teardowns (airflow.models.dag.DAG property)
template_ext (airflow.models.baseoperator.BaseOperator attribute)
(airflow.operators.bash.BashOperator attribute)
(airflow.operators.email.EmailOperator attribute)
(airflow.operators.generic_transfer.GenericTransfer attribute)
(airflow.operators.python.PythonVirtualenvOperator attribute)
template_fields (airflow.decorators.base.DecoratedOperator attribute)
(airflow.decorators.sensor.DecoratedSensorOperator attribute)
(airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.SumItOperator attribute)
(airflow.models.baseoperator.BaseOperator attribute)
(airflow.operators.bash.BashOperator attribute)
(airflow.operators.email.EmailOperator attribute)
(airflow.operators.generic_transfer.GenericTransfer attribute)
(airflow.operators.python.ExternalPythonOperator attribute)
(airflow.operators.python.PythonOperator attribute)
(airflow.operators.python.PythonVirtualenvOperator attribute)
(airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute)
(airflow.sensors.bash.BashSensor attribute)
(airflow.sensors.date_time.DateTimeSensor attribute)
(airflow.sensors.external_task.ExternalTaskMarker attribute)
(airflow.sensors.external_task.ExternalTaskSensor attribute)
(airflow.sensors.filesystem.FileSensor attribute)
(airflow.sensors.python.PythonSensor attribute)
template_fields_renderers (airflow.decorators.base.DecoratedOperator attribute)
(airflow.decorators.sensor.DecoratedSensorOperator attribute)
(airflow.models.baseoperator.BaseOperator attribute)
(airflow.operators.bash.BashOperator attribute)
(airflow.operators.email.EmailOperator attribute)
(airflow.operators.generic_transfer.GenericTransfer attribute)
(airflow.operators.python.PythonOperator attribute)
(airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute)
test() (airflow.models.dag.DAG method)
test_connection() (airflow.hooks.filesystem.FSHook method)
(airflow.hooks.package_index.PackageIndexHook method)
(airflow.models.connection.Connection method)
test_mode (airflow.models.taskinstance.TaskInstance attribute)
this_will_skip (in module airflow.example_dags.example_bash_operator)
TimeDeltaSensor (class in airflow.sensors.time_delta)
TimeDeltaSensorAsync (class in airflow.sensors.time_delta)
TimeDeltaTrigger (class in airflow.triggers.temporal)
TimeRestriction (class in airflow.timetables.base)
TimeSensor (class in airflow.sensors.time_sensor)
TimeSensorAsync (class in airflow.sensors.time_sensor)
timestamp (airflow.models.xcom.BaseXCom attribute)
Timetable (class in airflow.timetables.base)
timetable_description (airflow.models.dag.DagModel attribute)
timetables (airflow.example_dags.plugins.workday.WorkdayTimetablePlugin attribute)
timezone (airflow.models.dag.DagModel property)
tis (airflow.models.dagrun.TISchedulingDecision attribute)
TISchedulingDecision (class in airflow.models.dagrun)
topological_sort() (airflow.models.dag.DAG method)
TR (in module airflow.models.taskinstance)
tree_view() (airflow.models.dag.DAG method)
trigger (airflow.models.taskinstance.TaskInstance attribute)
(in module airflow.example_dags.example_trigger_controller_dag)
trigger_id (airflow.models.taskinstance.TaskInstance attribute)
trigger_timeout (airflow.models.taskinstance.TaskInstance attribute)
TriggerDagRunLink (class in airflow.operators.trigger_dagrun)
TriggerDagRunOperator (class in airflow.operators.trigger_dagrun)
triggerer_job (airflow.models.taskinstance.TaskInstance attribute)
TriggerEvent (class in airflow.triggers.base)
try_number (airflow.models.taskinstance.TaskInstance property)
(airflow.models.taskinstancekey.TaskInstanceKey attribute)
tutorial_etl_dag (in module airflow.example_dags.example_sensor_decorator)
tutorial_objectstorage() (in module airflow.example_dags.tutorial_objectstorage)
tutorial_taskflow_api() (in module airflow.example_dags.tutorial_taskflow_api)
tutorial_taskflow_api_virtualenv() (in module airflow.example_dags.tutorial_taskflow_api_virtualenv)
U
ui_color (airflow.example_dags.example_skip_dag.EmptySkipOperator attribute)
(airflow.models.baseoperator.BaseOperator attribute)
(airflow.operators.bash.BashOperator attribute)
(airflow.operators.email.EmailOperator attribute)
(airflow.operators.empty.EmptyOperator attribute)
(airflow.operators.generic_transfer.GenericTransfer attribute)
(airflow.operators.latest_only.LatestOnlyOperator attribute)
(airflow.operators.python.PythonOperator attribute)
(airflow.operators.smooth.SmoothOperator attribute)
(airflow.operators.subdag.SubDagOperator attribute)
(airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute)
(airflow.sensors.base.BaseSensorOperator attribute)
(airflow.sensors.external_task.ExternalTaskMarker attribute)
(airflow.sensors.external_task.ExternalTaskSensor attribute)
(airflow.sensors.filesystem.FileSensor attribute)
ui_fgcolor (airflow.models.baseoperator.BaseOperator attribute)
(airflow.operators.subdag.SubDagOperator attribute)
unfinished (airflow.utils.state.State attribute)
unfinished_dr_states (airflow.utils.state.State attribute)
unfinished_tis (airflow.models.dagrun.TISchedulingDecision attribute)
unixname (airflow.models.taskinstance.TaskInstance attribute)
UnmappableOperator
UnmappableXComLengthPushed
UnmappableXComTypePushed
UP_FOR_RESCHEDULE (airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
UP_FOR_RETRY (airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
update() (airflow.models.param.ParamsDict method)
(airflow.models.variable.Variable static method)
update_state() (airflow.models.dagrun.DagRun method)
updated_at (airflow.models.dagrun.DagRun attribute)
(airflow.models.dagrun.DagRunNote attribute)
(airflow.models.taskinstance.TaskInstance attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
UPSTREAM_FAILED (airflow.utils.state.State attribute)
(airflow.utils.state.TaskInstanceState attribute)
user_id (airflow.models.dagrun.DagRunNote attribute)
(airflow.models.taskinstance.TaskInstanceNote attribute)
V
val (airflow.models.variable.Variable property)
valid_modes (airflow.sensors.base.BaseSensorOperator attribute)
validate() (airflow.models.dag.DAG method)
(airflow.models.param.ParamsDict method)
(airflow.timetables._cron.CronMixin method)
(airflow.timetables.base.Timetable method)
(airflow.timetables.interval.DeltaDataIntervalTimetable method)
validate_run_id() (airflow.models.dagrun.DagRun method)
validate_schedule_and_params() (airflow.models.dag.DAG method)
value (airflow.models.xcom.BaseXCom attribute)
value_1 (in module airflow.example_dags.example_xcom)
value_2 (in module airflow.example_dags.example_xcom)
values() (airflow.models.param.ParamsDict method)
VAR_ENV_PREFIX (in module airflow.secrets.environment_variables)
Variable (class in airflow.models.variable)
verify_integrity() (airflow.models.dagrun.DagRun method)
virtualenv (airflow.decorators.TaskDecoratorCollection attribute)
W
wait (in module airflow.example_dags.example_time_delta_sensor_async)
with_try_number() (airflow.models.taskinstancekey.TaskInstanceKey method)
WorkdayTimetablePlugin (class in airflow.example_dags.plugins.workday)
worker_container_repository (in module airflow.example_dags.example_local_kubernetes_executor)
worker_container_tag (in module airflow.example_dags.example_local_kubernetes_executor)
X
XCom (in module airflow.models.xcom)
XCOM_EXECUTION_DATE_ISO (in module airflow.operators.trigger_dagrun)
xcom_pull() (airflow.models.baseoperator.BaseOperator static method)
(airflow.models.taskinstance.TaskInstance method)
xcom_push() (airflow.models.baseoperator.BaseOperator static method)
(airflow.models.taskinstance.TaskInstance method)
XCOM_RUN_ID (in module airflow.operators.trigger_dagrun)
XComForMappingNotPushed
XComNotFound
Y
yt_link (airflow.operators.smooth.SmoothOperator attribute)
Previous
Next
Was this entry helpful?
Suggest a change on this page