• Home
• Index

Index

_

__attrs_post_init__() (airflow.models.mappedoperator.MappedOperator method) (airflow.models.mappedoperator.OperatorPartial method) (airflow.sensors.external_task.ExternalTaskSensorLink method) __bool__() (airflow.sensors.base.PokeReturnValue 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) __del__() (airflow.models.mappedoperator.OperatorPartial method) __delitem__() (airflow.models.param.ParamsDict method) __enter__() (airflow.models.dag.DAG method) __eq__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.models.dagwarning.DagWarning method) (airflow.models.dataset.DagScheduleDatasetReference method) (airflow.models.dataset.DatasetDagRunQueue method) (airflow.models.dataset.DatasetModel method) (airflow.models.dataset.TaskOutletDatasetReference method) (airflow.models.taskinstance.SimpleTaskInstance method) (airflow.models.xcom_arg.PlainXComArg method) (airflow.timetables._cron.CronMixin method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) __exit__() (airflow.models.dag.DAG method) __getitem__() (airflow.models.param.ParamsDict method) (airflow.models.xcom_arg.PlainXComArg method) __getstate__() (airflow.models.baseoperator.BaseOperator method) __gt__() (airflow.models.baseoperator.BaseOperator method) __hash__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.models.dagwarning.DagWarning method) (airflow.models.dataset.DagScheduleDatasetReference method) (airflow.models.dataset.DatasetDagRunQueue method) (airflow.models.dataset.DatasetModel method) (airflow.models.dataset.TaskOutletDatasetReference method) (airflow.models.mappedoperator.MappedOperator method) __init_subclass__() (airflow.models.taskmixin.TaskMixin class method) __iter__() (airflow.models.param.ParamsDict method) (airflow.models.xcom_arg.PlainXComArg method) __len__() (airflow.models.param.ParamsDict method) __lshift__() (airflow.models.taskmixin.DependencyMixin 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.executors.base_executor.BaseExecutor 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.dataset.DagScheduleDatasetReference method) (airflow.models.dataset.DatasetDagRunQueue method) (airflow.models.dataset.DatasetEvent method) (airflow.models.dataset.DatasetModel method) (airflow.models.dataset.TaskOutletDatasetReference method) (airflow.models.mappedoperator.MappedOperator method) (airflow.models.mappedoperator.OperatorPartial method) (airflow.models.param.ParamsDict method) (airflow.models.pool.Pool method) (airflow.models.renderedtifields.RenderedTaskInstanceFields method) (airflow.models.serialized_dag.SerializedDagModel method) (airflow.models.slamiss.SlaMiss method) (airflow.models.taskfail.TaskFail method) (airflow.models.taskinstance.TaskInstance method) (airflow.models.tasklog.LogTemplate method) (airflow.models.variable.Variable method) (airflow.models.xcom.BaseXCom method) (airflow.models.xcom_arg.MapXComArg method) (airflow.models.xcom_arg.PlainXComArg method) (airflow.models.xcom_arg.ZipXComArg method) (airflow.timetables.events.EventsTimetable method)

__rlshift__() (airflow.models.taskmixin.DependencyMixin method) __rrshift__() (airflow.models.taskmixin.DependencyMixin method) __rshift__() (airflow.models.taskmixin.DependencyMixin 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.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.models.expandinput.NotFullyPopulated method) (airflow.models.xcom_arg.PlainXComArg method) __table_args__ (airflow.models.dag.DagModel attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.dagwarning.DagWarning attribute) (airflow.models.dataset.DagScheduleDatasetReference attribute) (airflow.models.dataset.DatasetDagRunQueue attribute) (airflow.models.dataset.DatasetEvent attribute) (airflow.models.dataset.DatasetModel attribute) (airflow.models.dataset.TaskOutletDatasetReference attribute) (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskmap.TaskMap attribute) (airflow.models.taskreschedule.TaskReschedule 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.dagcode.DagCode attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.dagwarning.DagWarning attribute) (airflow.models.dataset.DagScheduleDatasetReference attribute) (airflow.models.dataset.DatasetDagRunQueue attribute) (airflow.models.dataset.DatasetEvent attribute) (airflow.models.dataset.DatasetModel attribute) (airflow.models.dataset.TaskOutletDatasetReference attribute) (airflow.models.db_callback_request.DbCallbackRequest attribute) (airflow.models.errors.ImportError attribute) (airflow.models.log.Log attribute) (airflow.models.pool.Pool attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.tasklog.LogTemplate attribute) (airflow.models.taskmap.TaskMap attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.trigger.Trigger attribute) (airflow.models.variable.Variable attribute) (airflow.models.xcom.BaseXCom attribute)

A

AbstractOperator (class in airflow.models.abstractoperator) access_control (airflow.models.dag.DAG property) active_runs_of_dags() (airflow.models.dagrun.DagRun class method) add_inlets() (airflow.models.baseoperator.BaseOperator method) add_ondelete_for_mssql() (in module airflow.models.taskreschedule) add_outlets() (airflow.models.baseoperator.BaseOperator method) add_task() (airflow.models.dag.DAG method) add_tasks() (airflow.models.dag.DAG method) adopt_launched_task() (airflow.executors.kubernetes_executor.KubernetesExecutor method) AfterWorkdayTimetable (class in airflow.example_dags.plugins.workday) 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_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_passing_params_via_test_command module airflow.example_dags.example_python_operator 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.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_taskflow_api module airflow.example_dags.tutorial_taskflow_api_virtualenv module airflow.exceptions module airflow.executors module airflow.executors.base_executor module airflow.executors.celery_executor module airflow.executors.celery_kubernetes_executor module airflow.executors.dask_executor module airflow.executors.debug_executor module airflow.executors.executor_constants module airflow.executors.executor_loader module airflow.executors.kubernetes_executor module airflow.executors.local_executor module airflow.executors.local_kubernetes_executor module airflow.executors.sequential_executor module airflow.hooks module airflow.hooks.base module airflow.hooks.dbapi module airflow.hooks.filesystem module airflow.hooks.subprocess module airflow.macros module airflow.macros.hive module airflow.models module airflow.models.abstractoperator module airflow.models.base module airflow.models.baseoperator module airflow.models.connection module airflow.models.crypto module airflow.models.dag module airflow.models.dagbag module airflow.models.dagcode module airflow.models.dagparam module airflow.models.dagpickle module airflow.models.dagrun module airflow.models.dagwarning module

airflow.models.dataset module airflow.models.db_callback_request module airflow.models.errors module airflow.models.expandinput module airflow.models.log module airflow.models.mappedoperator module airflow.models.operator module airflow.models.param module airflow.models.pool module airflow.models.renderedtifields module airflow.models.serialized_dag module airflow.models.skipmixin module airflow.models.slamiss module airflow.models.taskfail module airflow.models.taskinstance module airflow.models.tasklog module airflow.models.taskmap module airflow.models.taskmixin module airflow.models.taskreschedule module airflow.models.trigger module airflow.models.variable module airflow.models.xcom module airflow.models.xcom_arg 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.secrets module airflow.secrets.base_secrets 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.utils.dag_parsing_context module AIRFLOW__{SECTION}__{KEY}, [1] AIRFLOW_CONFIG AIRFLOW_CONN_{CONN_ID}, [1] AIRFLOW_HOME AIRFLOW_VAR_{KEY} AIRFLOW_VAR_{VARIABLE_NAME} AirflowBadRequest AirflowClusterPolicyViolation AirflowConfigException AirflowDagCycleException AirflowDagDuplicatedIdException AirflowDagInconsistent AirflowException AirflowFailException AirflowFileParseException AirflowKubernetesScheduler (class in airflow.executors.kubernetes_executor) AirflowNotFoundException AirflowOptionalProviderFeatureException AirflowParsingContext (class in airflow.utils.dag_parsing_context) 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) app (in module airflow.executors.celery_executor) apply_upstream_relationship() (airflow.models.xcom_arg.XComArg static method) are_dependencies_met() (airflow.models.taskinstance.TaskInstance method) are_dependents_done() (airflow.models.taskinstance.TaskInstance method) as_dict() (airflow.models.taskinstance.SimpleTaskInstance method) assign_unassigned() (airflow.models.trigger.Trigger class method) association_table (in module airflow.models.dataset) autoregistered_dags (airflow.models.dag.DagContext attribute)

B

BackfillUnfinished bag_dag() (airflow.models.dagbag.DagBag method) Base (in module airflow.models.base) BASE_DIR (in module airflow.example_dags.example_python_operator) BaseBranchOperator (class in airflow.operators.branch) BaseExecutor (class in airflow.executors.base_executor) BaseHook (class in airflow.hooks.base) BaseOperator (class in airflow.models.baseoperator) BaseOperatorClassList (in module airflow.models.baseoperator) BaseOperatorLink (class in airflow.models.baseoperator) BaseOperatorMeta (class in airflow.models.baseoperator) BaseSecretsBackend (class in airflow.secrets.base_secrets) BaseSensorOperator (class in airflow.sensors.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() (in module airflow.example_dags.example_nested_branch_dag) BranchDateTimeOperator (class in airflow.operators.datetime) BranchDayOfWeekOperator (class in airflow.operators.weekday) BranchPythonOperator (class in airflow.operators.python) build_path() (airflow.secrets.base_secrets.BaseSecretsBackend static method) bulk_fetch() (airflow.models.trigger.Trigger class method) bulk_sync_to_db() (airflow.models.dag.DAG class method) (airflow.models.dagcode.DagCode class method) (airflow.models.serialized_dag.SerializedDagModel static method) bulk_write_to_db() (airflow.models.dag.DAG class method) BulkStateFetcher (class in airflow.executors.celery_executor)

C

calculate_dagrun_date_fields() (airflow.models.dag.DagModel method) callback_data (airflow.models.db_callback_request.DbCallbackRequest attribute) callback_sink (airflow.executors.base_executor.BaseExecutor attribute) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) callback_type (airflow.models.db_callback_request.DbCallbackRequest attribute) can_run (airflow.timetables.base.Timetable attribute) catchup (airflow.timetables.base.TimeRestriction attribute) celery_configuration (in module airflow.executors.celery_executor) CELERY_EXECUTOR (in module airflow.executors.executor_constants) CELERY_FETCH_ERR_MSG_HEADER (in module airflow.executors.celery_executor) CELERY_KUBERNETES_EXECUTOR (in module airflow.executors.executor_constants) CELERY_SEND_ERR_MSG_HEADER (in module airflow.executors.celery_executor) CeleryExecutor (class in airflow.executors.celery_executor) CeleryKubernetesExecutor (class in airflow.executors.celery_kubernetes_executor) chain() (in module airflow.models.baseoperator) Chainable (in module airflow.models.baseoperator) change_state() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.debug_executor.DebugExecutor method) 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) classpath (airflow.models.trigger.Trigger attribute) clean_unused() (airflow.models.trigger.Trigger class 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_not_launched_queued_tasks() (airflow.executors.kubernetes_executor.KubernetesExecutor method) clear_task_instances() (in module airflow.models.taskinstance) clear_xcom_data() (airflow.models.taskinstance.TaskInstance method) cli() (airflow.models.dag.DAG method) closest_ds_partition() (in module airflow.macros.hive) code() (airflow.models.dagcode.DagCode class method) coerce_resources() (in module airflow.models.baseoperator) coerce_timedelta() (in module airflow.models.baseoperator) COLLATION_ARGS (in module airflow.models.base) collect_dags() (airflow.models.dagbag.DagBag method)

collect_dags_from_db() (airflow.models.dagbag.DagBag method) command_as_list() (airflow.models.taskinstance.TaskInstance method) CommandType (in module airflow.executors.base_executor) 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) conn_type (airflow.hooks.base.DiscoverableHook attribute) (airflow.models.connection.Connection attribute) Connection (class in airflow.models.connection) ConnectionNotUnique ConnectorSource (class in airflow.executors.executor_loader) consuming_dags (airflow.models.dataset.DatasetModel attribute) CORE (airflow.executors.executor_loader.ConnectorSource attribute) create_dagrun() (airflow.models.dag.DAG method) create_entry_group (in module airflow.example_dags.example_complex) create_expand_input() (in module airflow.models.expandinput) create_or_update_pool() (airflow.models.pool.Pool static method) create_test_pipeline() (in module airflow.example_dags.example_skip_dag) create_timetable() (in module airflow.models.dag) created_at (airflow.models.dataset.DagScheduleDatasetReference attribute) (airflow.models.dataset.DatasetDagRunQueue attribute) (airflow.models.dataset.DatasetModel attribute) (airflow.models.dataset.TaskOutletDatasetReference attribute) (airflow.models.db_callback_request.DbCallbackRequest attribute) (airflow.models.tasklog.LogTemplate attribute) created_dagruns (airflow.models.dataset.DatasetEvent attribute) created_date (airflow.models.trigger.Trigger attribute) created_dttm (airflow.models.dagpickle.DagPickle attribute) CreatedTasksType (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_PATH (airflow.executors.executor_loader.ConnectorSource attribute)

D

dag (airflow.models.baseoperator.BaseOperator property) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.serialized_dag.SerializedDagModel property) (airflow.models.taskmixin.DAGNode attribute) 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_fileloc_hash() (airflow.models.dagcode.DagCode static method) dag_hash (airflow.models.dagrun.DagRun attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) dag_id (airflow.models.abstractoperator.AbstractOperator property) (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.dagwarning.DagWarning attribute) (airflow.models.dataset.DagScheduleDatasetReference attribute) (airflow.models.dataset.TaskOutletDatasetReference attribute) (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskmap.TaskMap attribute) (airflow.models.taskmixin.DAGNode property) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) (airflow.utils.dag_parsing_context.AirflowParsingContext attribute) dag_ids (airflow.models.dagbag.DagBag property) dag_model (airflow.models.dagrun.DagRun attribute) (airflow.models.serialized_dag.SerializedDagModel 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_run (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) dag_run_id (airflow.models.xcom.BaseXCom attribute) dag_runs (airflow.models.serialized_dag.SerializedDagModel attribute) DagBag (class in airflow.models.dagbag) dagbag_report() (airflow.models.dagbag.DagBag method) DagCode (class in airflow.models.dagcode) DagCodeNotFound DagConcurrencyLimitReached DagContext (class in airflow.models.dag) DagFileExists DagModel (class in airflow.models.dag) DAGNode (class in airflow.models.taskmixin) DagNotFound DagOwnerAttributes (class in airflow.models.dag) DagParam (class in airflow.models.param) DagPickle (class in airflow.models.dagpickle) DagRun (class in airflow.models.dagrun) DagRunAlreadyExists DagRunInfo (class in airflow.timetables.base) DagRunNotFound dags (airflow.models.dagbag.FileLoadStat attribute) dags_needing_dagruns() (airflow.models.dag.DagModel class method) DagScheduleDatasetReference (class in airflow.models.dataset) DagStateChangeCallback (in module airflow.models.dag) DagTag (class in airflow.models.dag) DagWarning (class in airflow.models.dagwarning) DagWarningType (class in airflow.models.dagwarning) DASK_EXECUTOR (in module airflow.executors.executor_constants) DaskExecutor (class in airflow.executors.dask_executor) data (airflow.models.serialized_dag.SerializedDagModel property) data_interval (airflow.timetables.base.DagRunInfo attribute) data_interval_end (airflow.models.dagrun.DagRun attribute) data_interval_for_events() (airflow.timetables.simple.DatasetTriggeredTimetable method) data_interval_start (airflow.models.dagrun.DagRun attribute) DataInterval (class in airflow.timetables.base) dataset (airflow.models.dataset.DagScheduleDatasetReference attribute) (airflow.models.dataset.DatasetEvent attribute) (airflow.models.dataset.TaskOutletDatasetReference attribute) dataset_id (airflow.models.dataset.DagScheduleDatasetReference attribute) (airflow.models.dataset.DatasetDagRunQueue attribute) (airflow.models.dataset.DatasetEvent attribute) (airflow.models.dataset.TaskOutletDatasetReference attribute) DatasetDagRunQueue (class in airflow.models.dataset) DatasetEvent (class in airflow.models.dataset) DatasetModel (class in airflow.models.dataset) DatasetTriggeredTimetable (class in airflow.timetables.simple) 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) DayOfWeekSensor (class in airflow.sensors.weekday) DbCallbackRequest (class in airflow.models.db_callback_request) 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_dump() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) DEBUG_EXECUTOR (in module airflow.executors.executor_constants) debug_info() (airflow.models.connection.Connection method) DebugExecutor (class in airflow.executors.debug_executor) decrypt() (airflow.models.crypto.FernetProtocol method) (airflow.models.crypto.NullFernet method) default_conn_name (airflow.hooks.base.DiscoverableHook attribute) DEFAULT_DAGRUNS_TO_EXAMINE (airflow.models.dagrun.DagRun attribute) DEFAULT_IGNORE_FIRST_DEPENDS_ON_PAST (in module airflow.models.abstractoperator) DEFAULT_OWNER (in module airflow.models.abstractoperator) DEFAULT_POOL_NAME (airflow.models.pool.Pool attribute) DEFAULT_POOL_SLOTS (in module airflow.models.abstractoperator) DEFAULT_PRIORITY_WEIGHT (in module airflow.models.abstractoperator) DEFAULT_QUEUE (in module airflow.models.abstractoperator) DEFAULT_RETRIES (in module airflow.models.abstractoperator) DEFAULT_RETRY_DELAY (in module airflow.models.abstractoperator) DEFAULT_SCHEDULE_INTERVAL (in module airflow.models.dag) DEFAULT_SECRETS_SEARCH_PATH (in module airflow.secrets) DEFAULT_TASK_EXECUTION_TIMEOUT (in module airflow.models.abstractoperator) DEFAULT_TRIGGER_RULE (in module airflow.models.abstractoperator) default_view (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) DEFAULT_VIEW_PRESETS (in module airflow.models.dag) DEFAULT_WEIGHT_RULE (in module airflow.models.abstractoperator) defer() (airflow.models.baseoperator.BaseOperator method) delete() (airflow.models.variable.Variable class method) (airflow.models.xcom.BaseXCom class method) delete_old_records() (airflow.models.renderedtifields.RenderedTaskInstanceFields class method) delete_pod() (airflow.executors.kubernetes_executor.AirflowKubernetesScheduler method) delete_pool() (airflow.models.pool.Pool static method) Delta (in module airflow.timetables.interval) DeltaDataIntervalTimetable (class in airflow.timetables.interval) DependencyMixin (class in airflow.models.taskmixin) depends_on_past (airflow.models.mappedoperator.MappedOperator property) deprecated_provider_since (airflow.exceptions.AirflowProviderDeprecationWarning attribute) deprecated_since (airflow.exceptions.RemovedInAirflow3Warning attribute) deps (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.sensors.base.BaseSensorOperator attribute) deps_for() (airflow.models.mappedoperator.MappedOperator static method) description (airflow.models.connection.Connection attribute) (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) (airflow.models.pool.Pool attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.variable.Variable attribute) (airflow.timetables.base.Timetable attribute) (airflow.timetables.simple.DatasetTriggeredTimetable attribute) (airflow.timetables.simple.NullTimetable attribute) (airflow.timetables.simple.OnceTimetable attribute) deserialize() (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) deserialize_xcom_arg() (in module airflow.models.xcom_arg) determine_kwargs() (airflow.operators.python.PythonOperator method) DICT (airflow.models.taskmap.TaskMapVariant attribute) DictOfListsExpandInput (class in airflow.models.expandinput) DiscoverableHook (class in airflow.hooks.base) do_work() (airflow.executors.local_executor.LocalWorker method) (airflow.executors.local_executor.LocalWorkerBase method) (airflow.executors.local_executor.QueuedLocalWorker method) doc (airflow.models.mappedoperator.MappedOperator property) doc_json (airflow.models.mappedoperator.MappedOperator property) doc_md (airflow.models.mappedoperator.MappedOperator property) (in module airflow.example_dags.tutorial_dag) doc_rst (airflow.models.mappedoperator.MappedOperator property) doc_yaml (airflow.models.mappedoperator.MappedOperator property) downstream_list (airflow.models.taskmixin.DAGNode property) downstream_task_ids (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.taskmixin.DAGNode attribute) dry_run() (airflow.models.baseoperator.BaseOperator method) (airflow.models.taskinstance.TaskInstance method) ds_add() (in module airflow.macros) ds_format() (in module airflow.macros) dttm (airflow.models.log.Log attribute) dump() (airflow.models.param.Param method) (airflow.models.param.ParamsDict method) DuplicateTaskIdFound duration (airflow.models.dagbag.FileLoadStat attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskreschedule.TaskReschedule attribute)

E

earliest (airflow.timetables.base.TimeRestriction attribute) elasticsearch_id (airflow.models.tasklog.LogTemplate attribute) email (airflow.models.mappedoperator.MappedOperator property) email_alert() (airflow.models.taskinstance.TaskInstance method) email_sent (airflow.models.slamiss.SlaMiss attribute) EmailOperator (class in airflow.operators.email) 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) encrypt() (airflow.models.crypto.FernetProtocol method) (airflow.models.crypto.NullFernet method) end (airflow.timetables.base.DataInterval attribute) end() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.debug_executor.DebugExecutor method) (airflow.executors.kubernetes_executor.KubernetesExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_executor.LocalExecutor.LimitedParallelism method) (airflow.executors.local_executor.LocalExecutor.UnlimitedParallelism method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) (airflow.executors.sequential_executor.SequentialExecutor method) end_date (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskmixin.DAGNode attribute) (airflow.models.taskreschedule.TaskReschedule attribute) ensure_xcomarg_return_value() (in module airflow.models.mappedoperator) 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) event (airflow.models.log.Log attribute) EventBufferValueType (in module airflow.executors.base_executor) 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_short_circuit_decorator() (in module airflow.example_dags.example_short_circuit_decorator) ExceptionWithTraceback (class in airflow.executors.celery_executor) execute() (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.BranchPythonOperator 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.time_delta.TimeDeltaSensorAsync method) (airflow.sensors.time_sensor.TimeSensorAsync method)

execute_async() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.debug_executor.DebugExecutor method) (airflow.executors.kubernetes_executor.KubernetesExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_executor.LocalExecutor.LimitedParallelism method) (airflow.executors.local_executor.LocalExecutor.UnlimitedParallelism method) (airflow.executors.sequential_executor.SequentialExecutor method) execute_callable() (airflow.operators.python.ExternalPythonOperator method) (airflow.operators.python.PythonOperator method) (airflow.operators.python.PythonVirtualenvOperator method) execute_command() (in module airflow.executors.celery_executor) execute_complete() (airflow.sensors.date_time.DateTimeSensorAsync method) (airflow.sensors.time_delta.TimeDeltaSensorAsync method) (airflow.sensors.time_sensor.TimeSensorAsync method) execute_work() (airflow.executors.local_executor.LocalWorkerBase method) execution_date (airflow.models.dagrun.DagRun attribute) (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) execution_timeout (airflow.models.mappedoperator.MappedOperator property) executor_config (airflow.models.mappedoperator.MappedOperator property) (airflow.models.taskinstance.TaskInstance attribute) ExecutorLoader (class in airflow.executors.executor_loader) executors (airflow.executors.executor_loader.ExecutorLoader attribute) ExecutorWorkType (in module airflow.executors.local_executor) expand() (airflow.models.mappedoperator.OperatorPartial method) expand_input (airflow.models.mappedoperator.MappedOperator attribute) EXPAND_INPUT_EMPTY (in module airflow.models.expandinput) expand_kwargs() (airflow.models.mappedoperator.OperatorPartial method) expand_mapped_task() (airflow.models.mappedoperator.MappedOperator method) ExpandInput (in module airflow.models.expandinput) external_executor_id (airflow.models.taskinstance.TaskInstance 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) (airflow.models.dataset.DatasetEvent attribute) (airflow.models.dataset.DatasetModel attribute) (airflow.models.log.Log attribute) extra_dejson (airflow.models.connection.Connection property) EXTRA_KEY (airflow.models.connection.Connection attribute) extra_links() (airflow.models.abstractoperator.AbstractOperator method)

F

fail() (airflow.executors.base_executor.BaseExecutor method) Feature releases FernetProtocol (class in airflow.models.crypto) fetch_celery_task_state() (in module airflow.executors.celery_executor) 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) (airflow.models.dagcode.DagCode attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) fileloc_hash (airflow.models.dagcode.DagCode attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) filename (airflow.models.errors.ImportError attribute) (airflow.models.tasklog.LogTemplate attribute) filepath (airflow.models.dag.DAG property) FileSensor (class in airflow.sensors.filesystem)

FileSyntaxError (class in airflow.exceptions) filter_for_tis() (airflow.models.taskinstance.TaskInstance static method) find() (airflow.models.dagrun.DagRun class method) find_duplicate() (airflow.models.dagrun.DagRun class method) find_for_task_instance() (airflow.models.taskreschedule.TaskReschedule static method) finished_tis (airflow.models.dagrun.TISchedulingDecision attribute) FLASK_APP folder (airflow.models.dag.DAG property) following_schedule() (airflow.models.dag.DAG method) from_dict() (airflow.models.taskinstance.SimpleTaskInstance class method) from_json() (airflow.models.connection.Connection class method) from_object() (airflow.models.trigger.Trigger class method) from_public() (airflow.models.dataset.DatasetModel class method) from_task_instance_xcom() (airflow.models.taskmap.TaskMap class method) from_ti() (airflow.models.taskinstance.SimpleTaskInstance class method) FSHook (class in airflow.hooks.filesystem) full_filepath (airflow.models.dag.DAG property)

G

generate_command() (airflow.models.taskinstance.TaskInstance static method) generate_run_id() (airflow.models.dagrun.DagRun static method) (airflow.timetables.base.Timetable method) (airflow.timetables.simple.DatasetTriggeredTimetable method) generate_value() (in module airflow.example_dags.example_xcomargs) GenericTransfer (class in airflow.operators.generic_transfer) get() (airflow.models.serialized_dag.SerializedDagModel class method) (airflow.models.variable.Variable class method) get_active_runs() (airflow.models.dag.DAG method) get_all() (airflow.models.dag.DagOwnerAttributes class method) get_all_paused_dag_ids() (airflow.models.dag.DagModel static method) get_base_pod_from_template() (in module airflow.executors.kubernetes_executor) get_callback_request() (airflow.models.db_callback_request.DbCallbackRequest method) get_code_by_fileloc() (airflow.models.dagcode.DagCode 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) 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) get_connection_from_secrets() (airflow.models.connection.Connection class method) get_connection_parameter_names() (in module airflow.secrets.local_filesystem) 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.abstractoperator.AbstractOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.dagbag.DagBag method) (airflow.models.dagrun.DagRun method) (airflow.models.mappedoperator.MappedOperator method) (airflow.models.serialized_dag.SerializedDagModel class method) get_dag_dependencies() (airflow.models.serialized_dag.SerializedDagModel class 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_executor() (airflow.executors.executor_loader.ExecutorLoader class method) get_default_pool() (airflow.models.pool.Pool static method) get_default_view() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) get_direct_relative_ids() (airflow.models.abstractoperator.AbstractOperator method) (airflow.models.taskmixin.DAGNode method) get_direct_relatives() (airflow.models.baseoperator.BaseOperator method) (airflow.models.taskmixin.DAGNode 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_event_buffer() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) get_external_task_group_task_ids() (airflow.sensors.external_task.ExternalTaskSensor method) get_extra() (airflow.models.connection.Connection method) get_extra_links() (airflow.models.abstractoperator.AbstractOperator method) get_failed_dep_statuses() (airflow.models.taskinstance.TaskInstance method) get_fernet() (in module airflow.models.crypto) get_flat_relative_ids() (airflow.models.abstractoperator.AbstractOperator method) get_flat_relatives() (airflow.models.abstractoperator.AbstractOperator method) get_hook() (airflow.hooks.base.BaseHook class method) (airflow.models.connection.Connection method) get_id_collation_args() (in module airflow.models.base) get_inlet_defs() (airflow.models.baseoperator.BaseOperator method) get_is_active() (airflow.models.dag.DAG method) get_is_paused() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method)

get_k8s_pod_yaml() (airflow.models.renderedtifields.RenderedTaskInstanceFields class method) get_last_dagrun() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (in module airflow.models.dag) get_last_updated_datetime() (airflow.models.serialized_dag.SerializedDagModel class method) get_latest_execution_date() (airflow.models.dag.DAG method) get_latest_runs() (airflow.models.dagrun.DagRun class method) get_latest_version_hash() (airflow.models.serialized_dag.SerializedDagModel class method) get_link() (airflow.models.baseoperator.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_many() (airflow.executors.celery_executor.BulkStateFetcher method) get_map_type_key() (in module airflow.models.expandinput) get_mappable_types() (in module airflow.models.expandinput) get_mapped_ti_count() (airflow.models.mappedoperator.MappedOperator method) get_max_last_updated_datetime() (airflow.models.serialized_dag.SerializedDagModel class method) get_merged_defaults() (in module airflow.models.baseoperator) get_next_data_interval() (airflow.models.dag.DAG 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_outlet_defs() (airflow.models.baseoperator.BaseOperator method) get_param() (airflow.models.param.ParamsDict method) get_parse_time_mapped_ti_count() (airflow.models.expandinput.DictOfListsExpandInput method) (airflow.models.expandinput.ListOfDictsExpandInput method) get_parsing_context() (in module airflow.utils.dag_parsing_context) 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_pool() (airflow.models.pool.Pool static method) get_pools() (airflow.models.pool.Pool static method) get_previous_dagrun() (airflow.models.dagrun.DagRun method) (airflow.models.taskinstance.TaskInstance method) get_previous_execution_date() (airflow.models.taskinstance.TaskInstance method) get_previous_scheduled_dagrun() (airflow.models.dagrun.DagRun method) get_previous_start_date() (airflow.models.taskinstance.TaskInstance method) get_previous_ti() (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() (airflow.models.dagrun.DagRun static method) get_run_data_interval() (airflow.models.dag.DAG 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.models.mappedoperator.MappedOperator 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) 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_task_map_length() (airflow.models.xcom_arg.MapXComArg method) (airflow.models.xcom_arg.PlainXComArg method) (airflow.models.xcom_arg.XComArg method) (airflow.models.xcom_arg.ZipXComArg method) get_template_context() (airflow.models.taskinstance.TaskInstance method) get_template_env() (airflow.models.abstractoperator.AbstractOperator method) (airflow.models.dag.DAG method) get_templated_fields() (airflow.models.renderedtifields.RenderedTaskInstanceFields class method) get_total_map_length() (airflow.models.expandinput.DictOfListsExpandInput method) (airflow.models.expandinput.ListOfDictsExpandInput method) get_truncated_error_traceback() (airflow.models.taskinstance.TaskInstance static method) get_ui_field_behaviour() (airflow.hooks.base.BaseHook class method) (airflow.hooks.base.DiscoverableHook static method) get_uri() (airflow.models.connection.Connection method) get_val() (airflow.models.variable.Variable method) get_value() (airflow.models.xcom.BaseXCom class method) get_variable() (airflow.secrets.base_secrets.BaseSecretsBackend 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) global_operator_extra_link_dict() (airflow.models.abstractoperator.AbstractOperator method)

H

handle_callback() (airflow.models.dag.DAG method) handle_failure() (airflow.models.taskinstance.TaskInstance method) has_dag() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dagcode.DagCode class method) (airflow.models.serialized_dag.SerializedDagModel class method) (airflow.models.taskmixin.DAGNode method) has_dag_runs() (airflow.models.dag.DAG method) has_import_errors (airflow.models.dag.DagModel attribute) has_task() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) (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) heartbeat() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) HIDE_ATTRS_FROM_UI (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.mappedoperator.MappedOperator attribute) hook_name (airflow.hooks.base.DiscoverableHook attribute) host (airflow.models.connection.Connection attribute) hostname (airflow.models.taskinstance.TaskInstance attribute)

I

id (airflow.models.connection.Connection attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.dataset.DatasetEvent attribute) (airflow.models.dataset.DatasetModel attribute) (airflow.models.db_callback_request.DbCallbackRequest attribute) (airflow.models.errors.ImportError attribute) (airflow.models.log.Log attribute) (airflow.models.pool.Pool attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.tasklog.LogTemplate attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.trigger.Trigger attribute) (airflow.models.variable.Variable attribute) ID_LEN (in module airflow.models.base) ids_for_triggerer() (airflow.models.trigger.Trigger class method) ignore_first_depends_on_past (airflow.models.mappedoperator.MappedOperator property) import_executor_cls() (airflow.executors.executor_loader.ExecutorLoader class method) ImportError (class in airflow.models.errors) InconsistentDataInterval infer_automated_data_interval() (airflow.models.dag.DAG method) 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.abstractoperator.AbstractOperator property) (airflow.models.baseoperator.BaseOperator property) (airflow.models.mappedoperator.MappedOperator property) (airflow.operators.empty.EmptyOperator attribute) init_on_load() (airflow.models.taskinstance.TaskInstance method) (airflow.models.xcom.BaseXCom method)

init_run_context() (airflow.models.taskinstance.TaskInstance method) inlets (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.mappedoperator.MappedOperator property) insert_mapping() (airflow.models.taskinstance.TaskInstance static method) interval() (airflow.timetables.base.DagRunInfo class method) InvalidStatsNameException is_active (airflow.models.dag.DagModel attribute) is_backfill (airflow.models.dagrun.DagRun property) is_default_pool() (airflow.models.pool.Pool static method) is_eligible_to_retry() (airflow.models.taskinstance.TaskInstance method) is_encrypted (airflow.models.connection.Connection attribute) (airflow.models.crypto.NullFernet attribute) (airflow.models.variable.Variable attribute) is_extra_encrypted (airflow.models.connection.Connection attribute) is_fixed_time_schedule() (airflow.models.dag.DAG method) is_mapped (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.mappedoperator.MappedOperator attribute) 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) items() (airflow.models.param.ParamsDict method) iter_dagrun_infos_between() (airflow.models.dag.DAG method) iter_invalid_owner_links() (airflow.models.dag.DAG method) iter_mapped_dependants() (airflow.models.abstractoperator.AbstractOperator method) iter_mapped_dependencies() (airflow.models.mappedoperator.MappedOperator method) iter_references() (airflow.models.xcom_arg.MapXComArg method) (airflow.models.xcom_arg.PlainXComArg method) (airflow.models.xcom_arg.XComArg method) (airflow.models.xcom_arg.ZipXComArg method) iter_xcom_args() (airflow.models.xcom_arg.XComArg static method)

J

job_id (airflow.executors.base_executor.BaseExecutor attribute) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor property) (airflow.models.taskinstance.TaskInstance attribute)

K

k8s (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor) k8s_pod_yaml (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) key (airflow.models.taskinstance.TaskInstance property) (airflow.models.taskinstance.TaskInstanceKey property) (airflow.models.variable.Variable attribute) (airflow.models.xcom.BaseXCom attribute) keys (airflow.models.taskmap.TaskMap attribute) KUBERNETES_EXECUTOR (in module airflow.executors.executor_constants)

KUBERNETES_QUEUE (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) KubernetesExecutor (class in airflow.executors.kubernetes_executor) KubernetesJobType (in module airflow.executors.kubernetes_executor) KubernetesJobWatcher (class in airflow.executors.kubernetes_executor) KubernetesResultsType (in module airflow.executors.kubernetes_executor) KubernetesWatchType (in module airflow.executors.kubernetes_executor) kwargs (airflow.models.mappedoperator.OperatorPartial attribute) (airflow.models.trigger.Trigger attribute)

L

label (airflow.models.taskmixin.DAGNode property) 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) last_updated (airflow.models.dagcode.DagCode attribute) (airflow.models.serialized_dag.SerializedDagModel 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) (airflow.models.mappedoperator.MappedOperator property) (airflow.models.taskmixin.DAGNode property) (airflow.models.taskmixin.DependencyMixin property) (airflow.models.xcom_arg.XComArg property) length (airflow.models.taskmap.TaskMap attribute) line_no (airflow.exceptions.FileSyntaxError attribute) link (airflow.models.dag.DagOwnerAttributes attribute) LIST (airflow.models.taskmap.TaskMapVariant attribute) ListOfDictsExpandInput (class in airflow.models.expandinput) load_connections() (in module airflow.secrets.local_filesystem) load_connections_dict() (in module airflow.secrets.local_filesystem) load_executor() (airflow.executors.executor_loader.ExecutorLoader class method) load_op_links (airflow.models.serialized_dag.SerializedDagModel attribute) load_variables() (in module airflow.secrets.local_filesystem) LOCAL_EXECUTOR (in module airflow.executors.executor_constants) LOCAL_KUBERNETES_EXECUTOR (in module airflow.executors.executor_constants) LocalExecutor (class in airflow.executors.local_executor) LocalExecutor.LimitedParallelism (class in airflow.executors.local_executor)

LocalExecutor.UnlimitedParallelism (class in airflow.executors.local_executor) LocalFilesystemBackend (class in airflow.secrets.local_filesystem) LocalKubernetesExecutor (class in airflow.executors.local_kubernetes_executor) LocalWorker (class in airflow.executors.local_executor) LocalWorkerBase (class in airflow.executors.local_executor) log (airflow.models.taskmixin.DAGNode property) Log (class in airflow.models.log) 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_operator) (in module airflow.example_dags.example_xcomargs) (in module airflow.example_dags.tutorial_taskflow_api_virtualenv) (in module airflow.executors.celery_executor) (in module airflow.executors.executor_loader) (in module airflow.hooks.base) (in module airflow.models.connection) (in module airflow.models.crypto) (in module airflow.models.dag) (in module airflow.models.dagcode) (in module airflow.models.serialized_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) logical_date (airflow.models.dagrun.DagRun property) (airflow.timetables.base.DagRunInfo property) login (airflow.models.connection.Connection attribute) LogTemplate (class in airflow.models.tasklog)

M

Major release map() (airflow.models.xcom_arg.MapXComArg method) (airflow.models.xcom_arg.PlainXComArg method) (airflow.models.xcom_arg.XComArg method) map_index (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskmap.TaskMap attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) MapCallables (in module airflow.models.xcom_arg) MappedOperator (class in airflow.models.mappedoperator) MapXComArg (class in airflow.models.xcom_arg) 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_active_tis_per_dag (airflow.models.mappedoperator.MappedOperator property) max_partition() (in module airflow.macros.hive) max_retry_delay (airflow.models.mappedoperator.MappedOperator property) max_tries (airflow.models.taskinstance.TaskInstance attribute) MAX_XCOM_SIZE (in module airflow.models.xcom) message (airflow.exceptions.FileSyntaxError attribute) (airflow.models.dagwarning.DagWarning attribute) metadata (in module airflow.models.base) MetastoreBackend (class in airflow.secrets.metastore) module 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_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_passing_params_via_test_command airflow.example_dags.example_python_operator 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.workday airflow.example_dags.subdags airflow.example_dags.subdags.subdag airflow.example_dags.tutorial airflow.example_dags.tutorial_dag airflow.example_dags.tutorial_taskflow_api airflow.example_dags.tutorial_taskflow_api_virtualenv airflow.exceptions airflow.executors airflow.executors.base_executor airflow.executors.celery_executor airflow.executors.celery_kubernetes_executor airflow.executors.dask_executor airflow.executors.debug_executor airflow.executors.executor_constants airflow.executors.executor_loader airflow.executors.kubernetes_executor airflow.executors.local_executor airflow.executors.local_kubernetes_executor airflow.executors.sequential_executor airflow.hooks airflow.hooks.base airflow.hooks.dbapi airflow.hooks.filesystem airflow.hooks.subprocess airflow.macros airflow.macros.hive airflow.models airflow.models.abstractoperator airflow.models.base airflow.models.baseoperator airflow.models.connection airflow.models.crypto airflow.models.dag airflow.models.dagbag airflow.models.dagcode airflow.models.dagparam airflow.models.dagpickle airflow.models.dagrun airflow.models.dagwarning airflow.models.dataset airflow.models.db_callback_request airflow.models.errors airflow.models.expandinput airflow.models.log airflow.models.mappedoperator airflow.models.operator airflow.models.param airflow.models.pool airflow.models.renderedtifields airflow.models.serialized_dag airflow.models.skipmixin airflow.models.slamiss airflow.models.taskfail airflow.models.taskinstance airflow.models.tasklog airflow.models.taskmap airflow.models.taskmixin airflow.models.taskreschedule airflow.models.trigger airflow.models.variable airflow.models.xcom airflow.models.xcom_arg 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.secrets airflow.secrets.base_secrets 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.utils.dag_parsing_context

my_py_command() (in module airflow.example_dags.example_passing_params_via_test_command)

N

name (airflow.example_dags.plugins.workday.WorkdayTimetablePlugin attribute) (airflow.models.baseoperator.BaseOperatorLink property) (airflow.models.dag.DagTag attribute) (airflow.operators.trigger_dagrun.TriggerDagRunLink attribute) (airflow.sensors.external_task.ExternalDagLink attribute) naming_convention (in module airflow.models.base) 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.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 node_id (airflow.models.abstractoperator.AbstractOperator property) (airflow.models.taskmixin.DAGNode property) NONEXISTENT_POOL (airflow.models.dagwarning.DagWarningType attribute) normalize_schedule() (airflow.models.dag.DAG method) normalized_schedule_interval (airflow.models.dag.DAG property) NOT_STARTED_MESSAGE (in module airflow.executors.base_executor) NotFullyPopulated notification_sent (airflow.models.slamiss.SlaMiss attribute) NullFernet (class in airflow.models.crypto) NullTimetable (class in airflow.timetables.simple) NUM_DAGS_PER_DAGRUN_QUERY (airflow.models.dag.DagModel attribute)

O

occupied_slots() (airflow.models.pool.Pool method) on_celery_import_modules() (in module airflow.executors.celery_executor) on_db_load() (airflow.models.connection.Connection method) (airflow.models.variable.Variable method) on_execute_callback (airflow.models.mappedoperator.MappedOperator property) on_failure_callback (airflow.models.mappedoperator.MappedOperator property) on_kill() (airflow.models.baseoperator.BaseOperator method) (airflow.operators.bash.BashOperator method) on_retry_callback (airflow.models.mappedoperator.MappedOperator property) on_success_callback (airflow.models.mappedoperator.MappedOperator property) OnceTimetable (class in airflow.timetables.simple) open (airflow.models.pool.PoolStats attribute) open_slots() (airflow.models.pool.Pool method) OPERATION_TIMEOUT (in module airflow.executors.celery_executor) operator (airflow.models.taskinstance.TaskInstance attribute) Operator (in module airflow.models.operator) operator_class (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.baseoperator.BaseOperator property) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.mappedoperator.OperatorPartial attribute) operator_extra_link_dict() (airflow.models.abstractoperator.AbstractOperator method) operator_extra_links (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.sensors.external_task.ExternalTaskMarker attribute) (airflow.sensors.external_task.ExternalTaskSensor attribute)

operator_name (airflow.models.abstractoperator.AbstractOperator property) (airflow.models.baseoperator.BaseOperator property) (airflow.models.mappedoperator.MappedOperator property) OperatorExpandArgument (in module airflow.models.expandinput) OperatorExpandKwargsArgument (in module airflow.models.expandinput) OperatorPartial (class in airflow.models.mappedoperator) operators (airflow.models.baseoperator.BaseOperatorLink attribute) order_queued_tasks_by_priority() (airflow.executors.base_executor.BaseExecutor method) ORIENTATION_PRESETS (in module airflow.models.dag) orm_deserialize_value() (airflow.models.xcom.BaseXCom method) outlets (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.mappedoperator.MappedOperator property) output (airflow.models.baseoperator.BaseOperator property) (airflow.models.mappedoperator.MappedOperator property) overwrite_params_with_dag_run_conf() (airflow.models.taskinstance.TaskInstance method) owner (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.dag.DAG property) (airflow.models.dag.DagOwnerAttributes attribute) (airflow.models.log.Log attribute) (airflow.models.mappedoperator.MappedOperator property) owners (airflow.models.dag.DagModel attribute)

P

PARALLELISM (in module airflow.executors.base_executor) Param (class in airflow.models.param) param() (airflow.models.dag.DAG method) params (airflow.models.mappedoperator.MappedOperator attribute) 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) parse_time_mapped_ti_count() (airflow.models.mappedoperator.MappedOperator method) partial (airflow.models.baseoperator.BaseOperator attribute) partial() (in module airflow.models.baseoperator) partial_kwargs (airflow.models.mappedoperator.MappedOperator attribute) partial_subset() (airflow.models.dag.DAG method) password (airflow.models.connection.Connection property) Patch releases periodic (airflow.timetables.base.Timetable attribute) pickle (airflow.models.dagpickle.DagPickle attribute) pickle() (airflow.models.dag.DAG method) pickle_hash (airflow.models.dagpickle.DagPickle attribute) 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) PlainXComArg (class in airflow.models.xcom_arg) PLUGIN (airflow.executors.executor_loader.ConnectorSource attribute) 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.mappedoperator.MappedOperator property) (airflow.models.pool.Pool attribute) (airflow.models.taskinstance.TaskInstance attribute) Pool (class in airflow.models.pool) pool_slots (airflow.models.mappedoperator.MappedOperator property) (airflow.models.taskinstance.TaskInstance attribute)

PoolNotFound PoolStats (class in airflow.models.pool) 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.models.mappedoperator.MappedOperator method) (airflow.sensors.base.BaseSensorOperator method) prepare_template() (airflow.models.abstractoperator.AbstractOperator method) prev_attempted_tries (airflow.models.taskinstance.TaskInstance property) prevent_duplicates() (in module airflow.models.mappedoperator) 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.taskinstance.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.abstractoperator.AbstractOperator attribute) (airflow.models.db_callback_request.DbCallbackRequest attribute) (airflow.models.mappedoperator.MappedOperator property) (airflow.models.taskinstance.TaskInstance attribute) priority_weight_total (airflow.models.abstractoperator.AbstractOperator property) process_error() (airflow.executors.kubernetes_executor.KubernetesJobWatcher method) process_file() (airflow.models.dagbag.DagBag method) process_status() (airflow.executors.kubernetes_executor.KubernetesJobWatcher method) process_watcher_task() (airflow.executors.kubernetes_executor.AirflowKubernetesScheduler method) processor_subdir (airflow.models.dag.DagModel attribute) (airflow.models.db_callback_request.DbCallbackRequest attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) producing_tasks (airflow.models.dataset.DatasetModel attribute) pull_value_from_bash_push() (in module airflow.example_dags.example_xcom) puller() (in module airflow.example_dags.example_xcom) purge_inactive_dag_warnings() (airflow.models.dagwarning.DagWarning class method) 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 (in module airflow.example_dags.example_python_operator) 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

query_for_task_instance() (airflow.models.taskreschedule.TaskReschedule static method) queue (airflow.models.mappedoperator.MappedOperator property) (airflow.models.taskinstance.TaskInstance attribute) queue_command() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) queue_records (airflow.models.dataset.DagScheduleDatasetReference attribute) queue_task_instance() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.debug_executor.DebugExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method)

queued (airflow.models.pool.PoolStats attribute) queued_at (airflow.models.dagrun.DagRun attribute) queued_by_job (in module airflow.models.taskinstance) queued_by_job_id (airflow.models.taskinstance.TaskInstance attribute) queued_dttm (airflow.models.taskinstance.TaskInstance attribute) queued_slots() (airflow.models.pool.Pool method) queued_tasks (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor property) QueuedLocalWorker (class in airflow.executors.local_executor) QueuedTaskInstanceType (in module airflow.executors.base_executor) QUEUEING_ATTEMPTS (in module airflow.executors.base_executor)

R

random() (in module airflow.macros) read_all_dags() (airflow.models.serialized_dag.SerializedDagModel class method) ready_for_retry() (airflow.models.taskinstance.TaskInstance method) reduced (airflow.models.taskinstance.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) remove_dag() (airflow.models.serialized_dag.SerializedDagModel class method) remove_deleted_code() (airflow.models.dagcode.DagCode class method) remove_deleted_dags() (airflow.models.serialized_dag.SerializedDagModel class method) RemovedInAirflow3Warning render_k8s_pod_yaml() (airflow.models.taskinstance.TaskInstance method) render_template() (airflow.models.abstractoperator.AbstractOperator method) render_template_fields() (airflow.models.abstractoperator.AbstractOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.mappedoperator.MappedOperator method) render_templates() (airflow.models.taskinstance.TaskInstance method) rendered_fields (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) rendered_task_instance_fields (airflow.models.taskinstance.TaskInstance attribute) RenderedTaskInstanceFields (class in airflow.models.renderedtifields) reschedule (airflow.sensors.base.BaseSensorOperator property) reschedule_date (airflow.models.taskreschedule.TaskReschedule attribute) resolve() (airflow.models.expandinput.DictOfListsExpandInput method) (airflow.models.expandinput.ListOfDictsExpandInput method) (airflow.models.param.DagParam method) (airflow.models.param.Param method) (airflow.models.xcom_arg.MapXComArg method) (airflow.models.xcom_arg.PlainXComArg method) (airflow.models.xcom_arg.XComArg method) (airflow.models.xcom_arg.ZipXComArg method) resolve_template_files() (airflow.models.abstractoperator.AbstractOperator method) (airflow.models.dag.DAG method) resolve_xcom_backend() (in module airflow.models.xcom) resource_version (airflow.executors.kubernetes_executor.ResourceVersion attribute) resources (airflow.models.mappedoperator.MappedOperator property) ResourceVersion (class in airflow.executors.kubernetes_executor) retries (airflow.models.mappedoperator.MappedOperator property) retry_delay (airflow.models.mappedoperator.MappedOperator property)

retry_exponential_backoff (airflow.models.mappedoperator.MappedOperator property) root_dag_id (airflow.models.dag.DagModel attribute) roots (airflow.models.baseoperator.BaseOperator property) (airflow.models.dag.DAG property) (airflow.models.mappedoperator.MappedOperator property) (airflow.models.taskmixin.DAGNode property) (airflow.models.taskmixin.DependencyMixin property) (airflow.models.xcom_arg.XComArg property) rotate_fernet_key() (airflow.models.connection.Connection method) (airflow.models.variable.Variable method) run() (airflow.executors.kubernetes_executor.KubernetesJobWatcher method) (airflow.executors.local_executor.LocalWorkerBase method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.models.taskinstance.TaskInstance method) run_after (airflow.timetables.base.DagRunInfo attribute) run_as_user (airflow.models.mappedoperator.MappedOperator property) run_command() (airflow.hooks.subprocess.SubprocessHook method) run_id (airflow.models.dagrun.DagRun attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskmap.TaskMap attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) run_next() (airflow.executors.kubernetes_executor.AirflowKubernetesScheduler method) run_ordering (airflow.timetables.base.Timetable attribute) run_pod_async() (airflow.executors.kubernetes_executor.AirflowKubernetesScheduler method) 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.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor property) (airflow.models.pool.PoolStats attribute) running_slots() (airflow.models.pool.Pool method)

S

safe_dag_id (airflow.models.dag.DagModel property) 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_slots() (airflow.models.pool.Pool method) 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) send_callback() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) send_sigterm() (airflow.hooks.subprocess.SubprocessHook method) send_task_to_executor() (in module airflow.executors.celery_executor) SEQUENTIAL_EXECUTOR (in module airflow.executors.executor_constants) SequentialExecutor (class in airflow.executors.sequential_executor) SerializationError serialize() (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) serialize_for_task_group() (airflow.models.baseoperator.BaseOperator method) (airflow.models.mappedoperator.MappedOperator method) (airflow.models.taskmixin.DAGNode method) serialize_value() (airflow.models.xcom.BaseXCom static method) serialize_xcom_arg() (in module airflow.models.xcom_arg) SerializedDagModel (class in airflow.models.serialized_dag) set() (airflow.models.variable.Variable class 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_downstream() (airflow.models.taskmixin.DAGNode method) (airflow.models.taskmixin.DependencyMixin method) (airflow.models.xcom_arg.XComArg 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_instance_state() (airflow.models.dag.DAG method) set_upstream() (airflow.models.taskmixin.DAGNode method) (airflow.models.taskmixin.DependencyMixin method) (airflow.models.xcom_arg.XComArg method) set_val() (airflow.models.variable.Variable method) set_xcomargs_dependencies() (airflow.models.baseoperator.BaseOperator method) setdefault() (airflow.models.variable.Variable class method) shallow_copy_attrs (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.python.PythonOperator attribute) ShortCircuitOperator (class in airflow.operators.python) should_run() (in module airflow.example_dags.example_branch_python_dop_operator_3) SimpleTaskInstance (class in airflow.models.taskinstance) size() (airflow.models.dagbag.DagBag method) skip() (airflow.models.skipmixin.SkipMixin method) skip_all_except() (airflow.models.skipmixin.SkipMixin method) SkipMixin (class in airflow.models.skipmixin) SkippedStatePropagationOptions (class in airflow.operators.subdag) sla (airflow.models.mappedoperator.MappedOperator property) SlaMiss (class in airflow.models.slamiss) SLAMissCallback (in module airflow.models.dag) slots (airflow.models.pool.Pool attribute) slots_available (airflow.executors.base_executor.BaseExecutor property) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor property) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor property) slots_stats() (airflow.models.pool.Pool static method) SmoothOperator (class in airflow.operators.smooth) source_code (airflow.models.dagcode.DagCode attribute) source_dag_id (airflow.models.dataset.DatasetEvent attribute)

source_dag_run (airflow.models.dataset.DatasetEvent attribute) source_map_index (airflow.models.dataset.DatasetEvent attribute) source_run_id (airflow.models.dataset.DatasetEvent attribute) source_task_id (airflow.models.dataset.DatasetEvent attribute) source_task_instance (airflow.models.dataset.DatasetEvent attribute) SQL_ALCHEMY_SCHEMA (in module airflow.models.base) stacktrace (airflow.models.errors.ImportError attribute) start (airflow.timetables.base.DataInterval attribute) (in module airflow.example_dags.example_subdag_operator) (in module airflow.example_dags.example_task_group) start() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.kubernetes_executor.KubernetesExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_executor.LocalExecutor.LimitedParallelism method) (airflow.executors.local_executor.LocalExecutor.UnlimitedParallelism method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) start_date (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskmixin.DAGNode attribute) (airflow.models.taskreschedule.TaskReschedule 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) status_code (airflow.exceptions.AirflowBadRequest attribute) (airflow.exceptions.AirflowException attribute) (airflow.exceptions.AirflowNotFoundException attribute) store_serialized_dags (airflow.models.dagbag.DagBag property) StringID() (in module airflow.models.base) sub_dag() (airflow.models.dag.DAG method) subdag (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.mappedoperator.MappedOperator 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) submit_event() (airflow.models.trigger.Trigger class method) submit_failure() (airflow.models.trigger.Trigger class method) subprocess_hook() (airflow.operators.bash.BashOperator method) SubprocessHook (class in airflow.hooks.subprocess) SubprocessResult (in module airflow.hooks.subprocess) success() (airflow.executors.base_executor.BaseExecutor method) summary (airflow.timetables._cron.CronMixin property) (airflow.timetables.base.Timetable property) (airflow.timetables.events.EventsTimetable property) (airflow.timetables.interval.DeltaDataIntervalTimetable property) (airflow.timetables.simple.DatasetTriggeredTimetable property) (airflow.timetables.simple.NullTimetable property) (airflow.timetables.simple.OnceTimetable property) supports_ad_hoc_ti_run (airflow.executors.celery_executor.CeleryExecutor attribute) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) (airflow.executors.kubernetes_executor.KubernetesExecutor attribute) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor attribute) supports_lineage (airflow.models.baseoperator.BaseOperator attribute) sync() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.debug_executor.DebugExecutor method) (airflow.executors.kubernetes_executor.AirflowKubernetesScheduler method) (airflow.executors.kubernetes_executor.KubernetesExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_executor.LocalExecutor.LimitedParallelism method) (airflow.executors.local_executor.LocalExecutor.UnlimitedParallelism method) (airflow.executors.sequential_executor.SequentialExecutor method) sync_to_db() (airflow.models.dag.DAG method) (airflow.models.dagbag.DagBag method) (airflow.models.dagcode.DagCode method)

T

T (in module airflow.models.baseoperator) t1 (in module airflow.example_dags.tutorial) TAG_MAX_LEN (in module airflow.models.dag) tags (airflow.models.dag.DagModel attribute) target_dag_id (airflow.models.dataset.DatasetDagRunQueue attribute) target_times_as_dates() (in module airflow.operators.datetime) task (airflow.models.dag.DAG property) (airflow.models.taskinstance.TaskInstance attribute) 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_end() (in module airflow.example_dags.example_task_group_decorator) task_group (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.dag.DAG property) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.taskmixin.DAGNode attribute) task_group_dict() (airflow.models.dag.DAG method) task_group_function() (in module airflow.example_dags.example_task_group_decorator) task_id (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.dataset.TaskOutletDatasetReference attribute) (airflow.models.log.Log attribute) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskmap.TaskMap attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) (airflow.utils.dag_parsing_context.AirflowParsingContext attribute) task_ids (airflow.models.dag.DAG property) task_instance (airflow.models.renderedtifields.RenderedTaskInstanceFields 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_start() (in module airflow.example_dags.example_task_group_decorator) task_type (airflow.models.abstractoperator.AbstractOperator property) (airflow.models.baseoperator.BaseOperator property) (airflow.models.mappedoperator.MappedOperator property) TaskAlreadyInTaskGroup TaskConcurrencyLimitReached TaskDeferralError TaskDeferred TaskFail (class in airflow.models.taskfail) TaskInstance (class in airflow.models.taskinstance) TaskInstanceInCelery (in module airflow.executors.celery_executor) TaskInstanceKey (class in airflow.models.taskinstance) TaskInstanceNotFound TaskInstanceStateType (in module airflow.models.taskinstance) TaskMap (class in airflow.models.taskmap) TaskMapVariant (class in airflow.models.taskmap) TaskMixin (class in airflow.models.taskmixin) TaskNotFound TaskOutletDatasetReference (class in airflow.models.dataset) TaskPostExecuteHook (in module airflow.models.baseoperator) TaskPreExecuteHook (in module airflow.models.baseoperator) TaskReschedule (class in airflow.models.taskreschedule) tasks (airflow.models.dag.DAG property) TaskStateChangeCallback (in module airflow.models.abstractoperator) TaskTuple (in module airflow.executors.base_executor) template_ext (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.mappedoperator.MappedOperator 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.models.abstractoperator.AbstractOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.mappedoperator.MappedOperator 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.models.baseoperator.BaseOperator attribute) (airflow.models.mappedoperator.MappedOperator 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) terminate() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.dask_executor.DaskExecutor method) (airflow.executors.debug_executor.DebugExecutor method) (airflow.executors.kubernetes_executor.AirflowKubernetesScheduler method) (airflow.executors.kubernetes_executor.KubernetesExecutor method) (airflow.executors.local_executor.LocalExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) (airflow.executors.sequential_executor.SequentialExecutor method) test_connection() (airflow.models.connection.Connection method) this_will_skip (in module airflow.example_dags.example_bash_operator) ti_selector_condition() (airflow.models.taskinstance.TaskInstance class method) TimeDeltaSensor (class in airflow.sensors.time_delta) TimeDeltaSensorAsync (class in airflow.sensors.time_delta) TimeRestriction (class in airflow.timetables.base) TimeSensor (class in airflow.sensors.time_sensor) TimeSensorAsync (class in airflow.sensors.time_sensor) timestamp (airflow.models.dagwarning.DagWarning attribute) (airflow.models.dataset.DatasetEvent attribute) (airflow.models.errors.ImportError attribute) (airflow.models.slamiss.SlaMiss attribute) (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) to_json() (airflow.models.pool.Pool method) topological_sort() (airflow.models.dag.DAG method) total (airflow.models.pool.PoolStats attribute) TR (in module airflow.models.taskinstance) tree_view() (airflow.models.dag.DAG method) trigger (airflow.models.taskinstance.TaskInstance attribute) Trigger (class in airflow.models.trigger) trigger (in module airflow.example_dags.example_trigger_controller_dag) trigger_id (airflow.models.taskinstance.TaskInstance attribute) trigger_rule (airflow.models.mappedoperator.MappedOperator property) trigger_tasks() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.debug_executor.DebugExecutor method) trigger_timeout (airflow.models.taskinstance.TaskInstance attribute) TriggerDagRunLink (class in airflow.operators.trigger_dagrun) TriggerDagRunOperator (class in airflow.operators.trigger_dagrun) triggerer_id (airflow.models.trigger.Trigger attribute) try_adopt_task_instances() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.kubernetes_executor.KubernetesExecutor method) (airflow.executors.local_kubernetes_executor.LocalKubernetesExecutor method) try_number (airflow.models.taskinstance.TaskInstance property) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskreschedule.TaskReschedule attribute) 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.models.mappedoperator.MappedOperator 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.models.mappedoperator.MappedOperator attribute) (airflow.operators.subdag.SubDagOperator attribute) unfinished_tis (airflow.models.dagrun.TISchedulingDecision attribute) unixname (airflow.models.taskinstance.TaskInstance attribute)

unmap() (airflow.models.abstractoperator.AbstractOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.mappedoperator.MappedOperator method) UnmappableOperator UnmappableXComLengthPushed UnmappableXComTypePushed UNPICKLEABLE_EXECUTORS (in module airflow.executors.executor_loader) update() (airflow.models.param.ParamsDict method) (airflow.models.variable.Variable class method) update_all_task_states() (airflow.executors.celery_executor.CeleryExecutor method) update_relative() (airflow.models.taskmixin.DependencyMixin method) update_state() (airflow.models.dagrun.DagRun method) update_task_state() (airflow.executors.celery_executor.CeleryExecutor method) updated_at (airflow.models.dataset.DagScheduleDatasetReference attribute) (airflow.models.dataset.DatasetModel attribute) (airflow.models.dataset.TaskOutletDatasetReference attribute) upstream_list (airflow.models.taskmixin.DAGNode property) upstream_task_ids (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.taskmixin.DAGNode attribute) uri (airflow.models.dataset.DatasetEvent property) (airflow.models.dataset.DatasetModel 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_airflow_tasks_run_command() (airflow.executors.base_executor.BaseExecutor static method) validate_command() (airflow.executors.base_executor.BaseExecutor static method) validate_mapping_kwargs() (in module airflow.models.mappedoperator) validate_schedule_and_params() (airflow.models.dag.DAG method)

ValidationSource (in module airflow.models.mappedoperator) value (airflow.models.expandinput.DictOfListsExpandInput attribute) (airflow.models.expandinput.ListOfDictsExpandInput attribute) (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) variant (airflow.models.taskmap.TaskMap property) verify_integrity() (airflow.models.dagrun.DagRun method)

W

wait (in module airflow.example_dags.example_time_delta_sensor_async) wait_for_downstream (airflow.models.mappedoperator.MappedOperator property) warning_type (airflow.models.dagwarning.DagWarning attribute) weight_rule (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.mappedoperator.MappedOperator property) with_try_number() (airflow.models.taskinstance.TaskInstanceKey method)

WorkdayTimetablePlugin (class in airflow.example_dags.plugins.workday) worker_container_repository (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor) worker_container_tag (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor) write() (airflow.models.renderedtifields.RenderedTaskInstanceFields method) write_dag() (airflow.models.serialized_dag.SerializedDagModel class method)

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_RETURN_KEY (in module airflow.models.xcom)

XCOM_RUN_ID (in module airflow.operators.trigger_dagrun) XCOM_SKIPMIXIN_FOLLOWED (in module airflow.models.skipmixin) XCOM_SKIPMIXIN_KEY (in module airflow.models.skipmixin) XCOM_SKIPMIXIN_SKIPPED (in module airflow.models.skipmixin) XComArg (class in airflow.models.xcom_arg) XComForMappingNotPushed XComNotFound

Y

yt_link (airflow.operators.smooth.SmoothOperator attribute)

Z

zip() (airflow.models.xcom_arg.PlainXComArg method) (airflow.models.xcom_arg.XComArg method)

ZipXComArg (class in airflow.models.xcom_arg)

PreviousNext

Was this entry helpful?