• Home
• Index

Index

_

__attrs_post_init__() (airflow.models.mappedoperator.MappedOperator method) (airflow.models.mappedoperator.OperatorPartial 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) (airflow.operators.python.PythonVirtualenvOperator 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.taskinstance.SimpleTaskInstance method) (airflow.models.xcom_arg.XComArg method) (airflow.sensors.smart_sensor.SensorWork method) (airflow.timetables.interval.CronDataIntervalTimetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) __exit__() (airflow.models.dag.DAG method) __getitem__() (airflow.models.param.ParamsDict method) (airflow.models.xcom_arg.XComArg 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.mappedoperator.MappedOperator method) __init_subclass__() (airflow.models.taskmixin.TaskMixin class method) __iter__() (airflow.models.param.ParamsDict method) (airflow.models.xcom_arg.XComArg method) __len__() (airflow.models.param.ParamsDict method) __lshift__() (airflow.models.taskmixin.DependencyMixin method) __lt__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) __mapper_args__ (airflow.operators.sql.SQLIntervalCheckOperator attribute) (airflow.operators.sql.SQLValueCheckOperator attribute) __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.DagTag method) (airflow.models.dagrun.DagRun 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.sensorinstance.SensorInstance 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.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.models.dag.InconsistentDataInterval method) (airflow.models.xcom_arg.XComArg method) __table_args__ (airflow.models.dag.DagModel attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.sensorinstance.SensorInstance 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.DagTag attribute) (airflow.models.dagcode.DagCode attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.dagrun.DagRun 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.sensorinstance.SensorInstance 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_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_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_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_etl_dag module airflow.example_dags.tutorial_taskflow_api_etl module airflow.example_dags.tutorial_taskflow_api_etl_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.base_hook module airflow.hooks.dbapi module airflow.hooks.dbapi_hook module airflow.hooks.docker_hook module airflow.hooks.druid_hook module airflow.hooks.filesystem module airflow.hooks.hdfs_hook module airflow.hooks.hive_hooks module airflow.hooks.http_hook module airflow.hooks.jdbc_hook module airflow.hooks.mssql_hook module airflow.hooks.mysql_hook module airflow.hooks.oracle_hook module airflow.hooks.pig_hook module airflow.hooks.postgres_hook module airflow.hooks.presto_hook module airflow.hooks.S3_hook module airflow.hooks.samba_hook module airflow.hooks.slack_hook module airflow.hooks.sqlite_hook module airflow.hooks.subprocess module airflow.hooks.webhdfs_hook module airflow.hooks.zendesk_hook 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.db_callback_request module airflow.models.errors 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.sensorinstance 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.bash_operator module airflow.operators.branch module airflow.operators.branch_operator module airflow.operators.check_operator module airflow.operators.dagrun_operator module airflow.operators.datetime module airflow.operators.docker_operator module airflow.operators.druid_check_operator module airflow.operators.dummy module airflow.operators.dummy_operator module airflow.operators.email module airflow.operators.email_operator module airflow.operators.empty module airflow.operators.gcs_to_s3 module airflow.operators.generic_transfer module airflow.operators.google_api_to_s3_transfer module airflow.operators.hive_operator module airflow.operators.hive_stats_operator module airflow.operators.hive_to_druid module airflow.operators.hive_to_mysql module airflow.operators.hive_to_samba_operator module airflow.operators.http_operator module airflow.operators.jdbc_operator module airflow.operators.latest_only module airflow.operators.latest_only_operator module airflow.operators.mssql_operator module airflow.operators.mssql_to_hive module airflow.operators.mysql_operator module airflow.operators.mysql_to_hive module airflow.operators.oracle_operator module airflow.operators.papermill_operator module airflow.operators.pig_operator module airflow.operators.postgres_operator module airflow.operators.presto_check_operator module airflow.operators.presto_to_mysql module airflow.operators.python module airflow.operators.python_operator module airflow.operators.redshift_to_s3_operator module airflow.operators.s3_file_transform_operator module airflow.operators.s3_to_hive_operator module airflow.operators.s3_to_redshift_operator module airflow.operators.slack_operator module airflow.operators.smooth module airflow.operators.sql module airflow.operators.sql_branch_operator module airflow.operators.sqlite_operator module airflow.operators.subdag module airflow.operators.subdag_operator 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.base_sensor_operator module airflow.sensors.bash module airflow.sensors.date_time module airflow.sensors.date_time_sensor module airflow.sensors.external_task module airflow.sensors.external_task_sensor module airflow.sensors.filesystem module airflow.sensors.hdfs_sensor module airflow.sensors.hive_partition_sensor module airflow.sensors.http_sensor module airflow.sensors.metastore_partition_sensor module airflow.sensors.named_hive_partition_sensor module airflow.sensors.python module airflow.sensors.s3_key_sensor module airflow.sensors.s3_prefix_sensor module airflow.sensors.smart_sensor module airflow.sensors.sql module airflow.sensors.sql_sensor module airflow.sensors.time_delta module airflow.sensors.time_delta_sensor module airflow.sensors.time_sensor module airflow.sensors.web_hdfs_sensor module airflow.sensors.weekday module airflow.timetables module airflow.timetables.base module airflow.timetables.events module airflow.timetables.interval module airflow.timetables.simple module AIRFLOW__{SECTION}__{KEY}, [1] AIRFLOW_CONFIG AIRFLOW_CONN_{CONN_ID}, [1] AIRFLOW_HOME AIRFLOW_SERIALIZABLE_CONTEXT_KEYS (airflow.operators.python.PythonVirtualenvOperator attribute) 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 AirflowRescheduleException AirflowSensorTimeout AirflowSkipException AirflowSmartSensorException 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)

B

BackfillUnfinished bag_dag() (airflow.models.dagbag.DagBag method) Base (in module airflow.models.base) BASE_SERIALIZABLE_CONTEXT_KEYS (airflow.operators.python.PythonVirtualenvOperator attribute) 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) 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) BaseSQLOperator (class in airflow.operators.sql) 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_1 (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) BranchSQLOperator (class in airflow.operators.sql) BranchSqlOperator (class in airflow.operators.sql_branch_operator) build_path() (airflow.secrets.base_secrets.BaseSecretsBackend static method) bulk_dump() (airflow.hooks.dbapi.DbApiHook method) bulk_fetch() (airflow.models.trigger.Trigger class method) bulk_load() (airflow.hooks.dbapi.DbApiHook 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

cache_key (airflow.sensors.smart_sensor.SensorWork property) CachedPokeWork (class in airflow.sensors.smart_sensor) 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) CheckOperator (class in airflow.operators.check_operator) 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_state() (airflow.sensors.smart_sensor.CachedPokeWork method) clear_task_instances() (in module airflow.models.taskinstance) clear_xcom_data() (airflow.models.taskinstance.TaskInstance method) cli() (airflow.models.dag.DAG method) close_sensor_logger() (airflow.sensors.smart_sensor.SensorWork method) closest_ds_partition() (in module airflow.macros.hive)

code() (airflow.models.dagcode.DagCode class method) coerce_resources() (in module airflow.models.baseoperator) coerce_retry_delay() (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) cond_true (in module airflow.example_dags.example_short_circuit_operator) conf (airflow.models.dagrun.DagRun attribute) config (in module airflow.sensors.smart_sensor) CONN_ENV_PREFIX (in module airflow.secrets.environment_variables) conn_id (airflow.models.connection.Connection attribute) conn_name_attr (airflow.hooks.base.DiscoverableHook attribute) (airflow.hooks.dbapi.DbApiHook attribute) conn_type (airflow.hooks.base.DiscoverableHook attribute) (airflow.models.connection.Connection attribute) connect() (airflow.hooks.dbapi.ConnectorProtocol method) Connection (class in airflow.models.connection) ConnectionNotUnique connector (airflow.hooks.dbapi.DbApiHook attribute) ConnectorProtocol (class in airflow.hooks.dbapi) ConnectorSource (class in airflow.executors.executor_loader) 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_new_task_handler() (airflow.sensors.smart_sensor.SensorWork static method) 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.db_callback_request.DbCallbackRequest attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.tasklog.LogTemplate attribute) created_date (airflow.models.trigger.Trigger attribute) created_dttm (airflow.models.dagpickle.DagPickle attribute) creating_job_id (airflow.models.dagrun.DagRun attribute) CronDataIntervalTimetable (class in airflow.timetables.interval) cross_downstream() (in module airflow.models.baseoperator) 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) dag2 (in module airflow.example_dags.example_branch_datetime_operator) dag_directory (airflow.models.db_callback_request.DbCallbackRequest attribute) 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.DagTag attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.sensorinstance.SensorInstance 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) dag_ids (airflow.models.dagbag.DagBag property) dag_model (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_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 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) DagStateChangeCallback (in module airflow.models.dag) DagTag (class in airflow.models.dag) 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_start (airflow.models.dagrun.DagRun attribute) DataInterval (class in airflow.timetables.base) date_range() (airflow.models.dag.DAG method) datetime_diff_for_humans() (in module airflow.macros) DateTimeSensor (class in airflow.sensors.date_time) DateTimeSensorAsync (class in airflow.sensors.date_time) DayOfWeekSensor (class in airflow.sensors.weekday) DbApiHook (class in airflow.hooks.dbapi) 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) (airflow.hooks.dbapi.DbApiHook attribute) DEFAULT_DAGRUNS_TO_EXAMINE (airflow.models.dagrun.DagRun attribute) 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) 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.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) deserialize_connection() (airflow.secrets.base_secrets.BaseSecretsBackend method) deserialize_value() (airflow.models.xcom.BaseXCom static method) determine_kwargs() (airflow.operators.python.PythonOperator method) (airflow.operators.python.PythonVirtualenvOperator method) DICT (airflow.models.taskmap.TaskMapVariant attribute) dictConfigurator (in module airflow.sensors.smart_sensor) 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_md (in module airflow.example_dags.tutorial_etl_dag) 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) DummyOperator (class in airflow.operators.dummy) (class in airflow.operators.dummy_operator) 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_21 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_22 (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) exception_info (airflow.sensors.smart_sensor.SensorExceptionInfo property) 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.PythonVirtualenvOperator method) (airflow.operators.python.ShortCircuitOperator method) (airflow.operators.smooth.SmoothOperator method) (airflow.operators.sql.BranchSQLOperator method) (airflow.operators.sql.SQLCheckOperator method) (airflow.operators.sql.SQLIntervalCheckOperator method) (airflow.operators.sql.SQLThresholdCheckOperator method) (airflow.operators.sql.SQLValueCheckOperator method) (airflow.operators.trigger_dagrun.TriggerDagRunOperator method) (airflow.sensors.base.BaseSensorOperator method) (airflow.sensors.date_time.DateTimeSensorAsync method) (airflow.sensors.smart_sensor.SmartSensorOperator 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.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_context (airflow.models.sensorinstance.SensorInstance attribute) execution_date (airflow.models.dagrun.DagRun attribute) (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) execution_fields (airflow.sensors.base.BaseSensorOperator 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_mapped_task() (airflow.models.mappedoperator.MappedOperator method) external_executor_id (airflow.models.taskinstance.TaskInstance attribute) external_trigger (airflow.models.dagrun.DagRun attribute) 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.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 flush_cached_sensor_poke_results() (airflow.sensors.smart_sensor.SmartSensorOperator method) folder (airflow.models.dag.DAG property) following_schedule() (airflow.models.dag.DAG method) formatter_config (in module airflow.sensors.smart_sensor) 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_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) 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_autocommit() (airflow.hooks.dbapi.DbApiHook method) get_base_pod_from_template() (in module airflow.executors.kubernetes_executor) get_callback_request() (airflow.models.db_callback_request.DbCallbackRequest method) get_classpath() (airflow.models.sensorinstance.SensorInstance static 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.dbapi.DbApiHook 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_cursor() (airflow.hooks.dbapi.DbApiHook 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) 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.sensorinstance.SensorInstance method) (airflow.models.taskinstance.TaskInstance method) get_dagruns_between() (airflow.models.dag.DAG method) get_db_hook() (airflow.operators.sql.BaseSQLOperator method) 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_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_execution_context() (airflow.sensors.base.BaseSensorOperator 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_first() (airflow.hooks.dbapi.DbApiHook method) 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.ExternalTaskSensorLink 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_mappable_types() (in module airflow.models.mappedoperator) 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_pandas_df() (airflow.hooks.dbapi.DbApiHook method) get_pandas_df_by_chunks() (airflow.hooks.dbapi.DbApiHook method) get_param() (airflow.models.param.ParamsDict method) get_password() (airflow.models.connection.Connection method) get_path() (airflow.hooks.filesystem.FSHook method) get_paused_dag_ids() (airflow.models.dag.DagModel static method) get_poke_context() (airflow.sensors.base.BaseSensorOperator 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_python_source() (airflow.operators.python.PythonVirtualenvOperator method) get_records() (airflow.hooks.dbapi.DbApiHook 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_sqlalchemy_engine() (airflow.hooks.dbapi.DbApiHook 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_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_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.hooks.dbapi.DbApiHook method) (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) GoogleApiToS3Transfer (class in airflow.operators.google_api_to_s3_transfer)

H

handle_callback() (airflow.models.dag.DAG method) handle_failure() (airflow.models.taskinstance.TaskInstance method) handle_failure_with_callback() (airflow.models.taskinstance.TaskInstance method) handler_config (in module airflow.sensors.smart_sensor) 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_value (airflow.models.param.Param property) hashcode (airflow.models.sensorinstance.SensorInstance attribute) 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) HiveToDruidTransfer (class in airflow.operators.hive_to_druid) HiveToMySqlTransfer (class in airflow.operators.hive_to_mysql) 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.db_callback_request.DbCallbackRequest attribute) (airflow.models.errors.ImportError attribute) (airflow.models.log.Log attribute) (airflow.models.pool.Pool attribute) (airflow.models.sensorinstance.SensorInstance 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) 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) ingest (in module airflow.example_dags.example_branch_labels) inherits_from_dummy_operator (airflow.operators.dummy.DummyOperator property) 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.mappedoperator.MappedOperator property) insert_mapping() (airflow.models.taskinstance.TaskInstance static method) insert_rows() (airflow.hooks.dbapi.DbApiHook method) interval() (airflow.timetables.base.DagRunInfo class method) IntervalCheckOperator (class in airflow.operators.check_operator) 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_expired() (airflow.sensors.smart_sensor.CachedPokeWork method) (airflow.sensors.smart_sensor.SensorExceptionInfo method) is_extra_encrypted (airflow.models.connection.Connection attribute) is_fixed_time_schedule() (airflow.models.dag.DAG method) is_infra_failure (airflow.sensors.smart_sensor.SensorExceptionInfo property) 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_smart_sensor_compatible() (airflow.models.baseoperator.BaseOperator method) (airflow.sensors.base.BaseSensorOperator method) 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_mapped_dependants() (airflow.models.taskmixin.DAGNode method) iter_mapped_dependencies() (airflow.models.mappedoperator.MappedOperator 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) LIST (airflow.models.taskmap.TaskMapVariant attribute) load_connections() (in module airflow.secrets.local_filesystem) load_connections_dict() (in module airflow.secrets.local_filesystem) load_error_file() (in module airflow.models.taskinstance) 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_etl_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() (airflow.sensors.smart_sensor.SensorWork method) 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_index (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.sensorinstance.SensorInstance 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) Mappable (in module airflow.models.mappedoperator) MAPPABLE_LITERAL_TYPES (in module airflow.models.mappedoperator) mapped_arguments_validated_by_init (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.python.PythonOperator attribute) mapped_kwargs (airflow.models.mappedoperator.MappedOperator attribute) MappedOperator (class in airflow.models.mappedoperator) 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_tries (airflow.models.taskinstance.TaskInstance attribute) MAX_XCOM_SIZE (in module airflow.models.xcom) message (airflow.exceptions.FileSyntaxError 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_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_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_etl_dag airflow.example_dags.tutorial_taskflow_api_etl airflow.example_dags.tutorial_taskflow_api_etl_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.base_hook airflow.hooks.dbapi airflow.hooks.dbapi_hook airflow.hooks.docker_hook airflow.hooks.druid_hook airflow.hooks.filesystem airflow.hooks.hdfs_hook airflow.hooks.hive_hooks airflow.hooks.http_hook airflow.hooks.jdbc_hook airflow.hooks.mssql_hook airflow.hooks.mysql_hook airflow.hooks.oracle_hook airflow.hooks.pig_hook airflow.hooks.postgres_hook airflow.hooks.presto_hook airflow.hooks.S3_hook airflow.hooks.samba_hook airflow.hooks.slack_hook airflow.hooks.sqlite_hook airflow.hooks.subprocess airflow.hooks.webhdfs_hook airflow.hooks.zendesk_hook 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.db_callback_request airflow.models.errors airflow.models.log airflow.models.mappedoperator airflow.models.operator airflow.models.param airflow.models.pool airflow.models.renderedtifields airflow.models.sensorinstance 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.bash_operator airflow.operators.branch airflow.operators.branch_operator airflow.operators.check_operator airflow.operators.dagrun_operator airflow.operators.datetime airflow.operators.docker_operator airflow.operators.druid_check_operator airflow.operators.dummy airflow.operators.dummy_operator airflow.operators.email airflow.operators.email_operator airflow.operators.empty airflow.operators.gcs_to_s3 airflow.operators.generic_transfer airflow.operators.google_api_to_s3_transfer airflow.operators.hive_operator airflow.operators.hive_stats_operator airflow.operators.hive_to_druid airflow.operators.hive_to_mysql airflow.operators.hive_to_samba_operator airflow.operators.http_operator airflow.operators.jdbc_operator airflow.operators.latest_only airflow.operators.latest_only_operator airflow.operators.mssql_operator airflow.operators.mssql_to_hive airflow.operators.mysql_operator airflow.operators.mysql_to_hive airflow.operators.oracle_operator airflow.operators.papermill_operator airflow.operators.pig_operator airflow.operators.postgres_operator airflow.operators.presto_check_operator airflow.operators.presto_to_mysql airflow.operators.python airflow.operators.python_operator airflow.operators.redshift_to_s3_operator airflow.operators.s3_file_transform_operator airflow.operators.s3_to_hive_operator airflow.operators.s3_to_redshift_operator airflow.operators.slack_operator airflow.operators.smooth airflow.operators.sql airflow.operators.sql_branch_operator airflow.operators.sqlite_operator airflow.operators.subdag airflow.operators.subdag_operator 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.base_sensor_operator airflow.sensors.bash airflow.sensors.date_time airflow.sensors.date_time_sensor airflow.sensors.external_task airflow.sensors.external_task_sensor airflow.sensors.filesystem airflow.sensors.hdfs_sensor airflow.sensors.hive_partition_sensor airflow.sensors.http_sensor airflow.sensors.metastore_partition_sensor airflow.sensors.named_hive_partition_sensor airflow.sensors.python airflow.sensors.s3_key_sensor airflow.sensors.s3_prefix_sensor airflow.sensors.smart_sensor airflow.sensors.sql airflow.sensors.sql_sensor airflow.sensors.time_delta airflow.sensors.time_delta_sensor airflow.sensors.time_sensor airflow.sensors.web_hdfs_sensor airflow.sensors.weekday airflow.timetables airflow.timetables.base airflow.timetables.events airflow.timetables.interval airflow.timetables.simple

MsSqlToHiveTransfer (class in airflow.operators.mssql_to_hive) my_py_command() (in module airflow.example_dags.example_passing_params_via_test_command) MySqlToHiveTransfer (class in airflow.operators.mysql_to_hive)

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.ExternalTaskSensorLink attribute) next_dagrun (airflow.models.dag.DagModel attribute) next_dagrun_after_date() (airflow.models.dag.DAG method) next_dagrun_create_after (airflow.models.dag.DagModel attribute) next_dagrun_data_interval (airflow.models.dag.DagModel property) next_dagrun_data_interval_end (airflow.models.dag.DagModel attribute) next_dagrun_data_interval_start (airflow.models.dag.DagModel attribute) next_dagrun_info() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method) (airflow.models.dag.DAG method) (airflow.timetables.base.Timetable method) (airflow.timetables.events.EventsTimetable method) (airflow.timetables.simple.NullTimetable method) (airflow.timetables.simple.OnceTimetable 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) normalize_schedule() (airflow.models.dag.DAG method) normalized_schedule_interval (airflow.models.dag.DAG property) NOT_STARTED_MESSAGE (in module airflow.executors.base_executor) 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) (airflow.sensors.smart_sensor.SmartSensorOperator method) on_retry_callback (airflow.models.mappedoperator.MappedOperator property) on_success_callback (airflow.models.mappedoperator.MappedOperator property) OnceTimetable (class in airflow.timetables.simple) op_classpath (airflow.models.sensorinstance.SensorInstance attribute) open (airflow.models.pool.PoolStats attribute) open_slots() (airflow.models.pool.Pool method) OPERATION_TIMEOUT (in module airflow.executors.celery_executor) operator (airflow.models.sensorinstance.SensorInstance attribute) (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.ExternalTaskSensor property) 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.mappedoperator.MappedOperator property) output (airflow.models.baseoperator.BaseOperator 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.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_boolean() (in module airflow.operators.sql) 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 PENDULUM_SERIALIZABLE_CONTEXT_KEYS (airflow.operators.python.PythonVirtualenvOperator attribute) 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) 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.smart_sensor.SmartSensorOperator method) (airflow.sensors.sql.SqlSensor method) (airflow.sensors.time_delta.TimeDeltaSensor method) (airflow.sensors.time_sensor.TimeSensor method) (airflow.sensors.weekday.DayOfWeekSensor method) poke_context (airflow.models.sensorinstance.SensorInstance attribute) 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) PrestoCheckOperator (class in airflow.operators.presto_check_operator) PrestoIntervalCheckOperator (class in airflow.operators.presto_check_operator) PrestoToMySqlTransfer (class in airflow.operators.presto_to_mysql) PrestoValueCheckOperator (class in airflow.operators.presto_check_operator) 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) pull_value_from_bash_push() (in module airflow.example_dags.example_xcom) puller() (in module airflow.example_dags.example_xcom) push() (airflow.operators.sql.SQLThresholdCheckOperator method) (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) 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_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) ratio_formulas (airflow.operators.sql.SQLIntervalCheckOperator attribute) read_all_dags() (airflow.models.serialized_dag.SerializedDagModel class method) ready_for_retry() (airflow.models.taskinstance.TaskInstance method) RedshiftToS3Transfer (class in airflow.operators.redshift_to_s3_operator) 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) register() (airflow.models.sensorinstance.SensorInstance class method) register_in_sensor_service() (airflow.sensors.base.BaseSensorOperator 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) 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.param.DagParam method) (airflow.models.param.Param method) (airflow.models.xcom_arg.XComArg 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.hooks.dbapi.DbApiHook 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_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_time_mapped_ti_count() (airflow.models.mappedoperator.MappedOperator method) 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

S3ToHiveTransfer (class in airflow.operators.s3_to_hive_operator) S3ToRedshiftTransfer (class in airflow.operators.s3_to_redshift_operator) safe_dag_id (airflow.models.dag.DagModel property) schedulable_tis (airflow.models.dagrun.TISchedulingDecision attribute) schedule_interval (airflow.models.dag.DagModel attribute) schedule_tis() (airflow.models.dagrun.DagRun 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) SensorExceptionInfo (class in airflow.sensors.smart_sensor) SensorInstance (class in airflow.models.sensorinstance) SensorWork (class in airflow.sensors.smart_sensor) 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) 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) SerializedDagModel (class in airflow.models.serialized_dag) set() (airflow.models.variable.Variable class method) set_autocommit() (airflow.hooks.dbapi.DbApiHook 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_error_file() (in module airflow.models.taskinstance) set_extra() (airflow.models.connection.Connection method) set_infra_failure_timeout() (airflow.sensors.smart_sensor.SensorExceptionInfo method) set_is_paused() (airflow.models.dag.DagModel method) set_latest_exception() (airflow.sensors.smart_sensor.SensorExceptionInfo method) set_password() (airflow.models.connection.Connection method) set_state() (airflow.models.dagrun.DagRun method) (airflow.models.taskinstance.TaskInstance method) (airflow.sensors.smart_sensor.CachedPokeWork method) set_task_instance_state() (airflow.models.dag.DAG method) set_to_flush() (airflow.sensors.smart_sensor.CachedPokeWork 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) shardcode (airflow.models.sensorinstance.SensorInstance attribute) ShortCircuitOperator (class in airflow.operators.python) should_fail_current_run() (airflow.sensors.smart_sensor.SensorExceptionInfo method) 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) 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) SmartSensorOperator (class in airflow.sensors.smart_sensor)

SmoothOperator (class in airflow.operators.smooth) source_code (airflow.models.dagcode.DagCode attribute) SQL_ALCHEMY_SCHEMA (in module airflow.models.base) SQLCheckOperator (class in airflow.operators.sql) SQLIntervalCheckOperator (class in airflow.operators.sql) SqlSensor (class in airflow.sensors.sql) SQLThresholdCheckOperator (class in airflow.operators.sql) SQLValueCheckOperator (class in airflow.operators.sql) 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.sensorinstance.SensorInstance 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.sensorinstance.SensorInstance attribute) (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.base.Timetable property) (airflow.timetables.events.EventsTimetable property) (airflow.timetables.interval.CronDataIntervalTimetable property) (airflow.timetables.interval.DeltaDataIntervalTimetable 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_autocommit (airflow.hooks.dbapi.DbApiHook 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) tags (airflow.models.dag.DagModel attribute) target_times_as_dates() (in module airflow.operators.datetime) task (airflow.models.dag.DAG property) (airflow.models.taskinstance.TaskInstance attribute) task() (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_function() (in module airflow.example_dags.example_task_group_decorator) task_id (airflow.models.abstractoperator.AbstractOperator attribute) (airflow.models.log.Log attribute) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.sensorinstance.SensorInstance 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) 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_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 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) (airflow.operators.sql.BranchSQLOperator attribute) (airflow.operators.sql.SQLCheckOperator attribute) (airflow.operators.sql.SQLIntervalCheckOperator attribute) (airflow.operators.sql.SQLThresholdCheckOperator attribute) (airflow.operators.sql.SQLValueCheckOperator attribute) (airflow.sensors.sql.SqlSensor 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.PythonOperator attribute) (airflow.operators.python.PythonVirtualenvOperator attribute) (airflow.operators.sql.BranchSQLOperator attribute) (airflow.operators.sql.SQLCheckOperator attribute) (airflow.operators.sql.SQLIntervalCheckOperator attribute) (airflow.operators.sql.SQLThresholdCheckOperator attribute) (airflow.operators.sql.SQLValueCheckOperator 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) (airflow.sensors.sql.SqlSensor 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.sql.BranchSQLOperator attribute) (airflow.operators.sql.SQLCheckOperator attribute) (airflow.operators.sql.SQLIntervalCheckOperator attribute) (airflow.operators.sql.SQLThresholdCheckOperator attribute) (airflow.operators.sql.SQLValueCheckOperator 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.hooks.dbapi.DbApiHook method) (airflow.models.connection.Connection method) this_will_skip (in module airflow.example_dags.example_bash_operator) ThresholdCheckOperator (class in airflow.operators.check_operator) ti_key (airflow.sensors.smart_sensor.SensorWork property) 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.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.sensorinstance.SensorInstance property) (airflow.models.taskinstance.TaskInstance property) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskreschedule.TaskReschedule attribute) tutorial_etl_dag (in module airflow.example_dags.tutorial_taskflow_api_etl) tutorial_taskflow_api_etl() (in module airflow.example_dags.tutorial_taskflow_api_etl) tutorial_taskflow_api_etl_virtualenv() (in module airflow.example_dags.tutorial_taskflow_api_etl_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.sql.BranchSQLOperator attribute) (airflow.operators.sql.SQLCheckOperator attribute) (airflow.operators.sql.SQLIntervalCheckOperator attribute) (airflow.operators.sql.SQLValueCheckOperator 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) (airflow.sensors.smart_sensor.SmartSensorOperator attribute) (airflow.sensors.sql.SqlSensor attribute)

ui_fgcolor (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.mappedoperator.MappedOperator attribute) (airflow.operators.sql.BranchSQLOperator attribute) (airflow.operators.subdag.SubDagOperator attribute) unfinished_tis (airflow.models.dagrun.TISchedulingDecision attribute) unixname (airflow.models.taskinstance.TaskInstance attribute) unmap() (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.sensorinstance.SensorInstance attribute) upstream_list (airflow.models.taskmixin.DAGNode property) upstream_task_ids (airflow.models.mappedoperator.MappedOperator attribute) (airflow.models.taskmixin.DAGNode 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.base.Timetable method) (airflow.timetables.interval.CronDataIntervalTimetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) validate_command() (airflow.executors.base_executor.BaseExecutor static method) validate_mapped_arguments() (airflow.models.baseoperator.BaseOperator class 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.xcom.BaseXCom attribute) value_1 (in module airflow.example_dags.example_xcom) value_2 (in module airflow.example_dags.example_xcom) ValueCheckOperator (class in airflow.operators.check_operator) 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) 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

Y

yt_link (airflow.operators.smooth.SmoothOperator attribute)

PreviousNext

Was this entry helpful?