• Home
• Index

Index

_

__deepcopy__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.operators.python.PythonVirtualenvOperator method) __enter__() (airflow.models.dag.DAG method) __eq__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG 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) __lshift__() (airflow.models.taskmixin.TaskMixin 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.param.NoValueSentinel 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.taskinstance.TaskInstance method) (airflow.models.variable.Variable method) (airflow.models.xcom.BaseXCom method)

__rlshift__() (airflow.models.taskmixin.TaskMixin method) __rrshift__() (airflow.models.taskmixin.TaskMixin method) __rshift__() (airflow.models.taskmixin.TaskMixin method) __setattr__() (airflow.models.baseoperator.BaseOperator method) __setitem__() (airflow.models.param.ParamsDict method) __setstate__() (airflow.models.baseoperator.BaseOperator method) __str__() (airflow.exceptions.AirflowDagDuplicatedIdException method) (airflow.exceptions.AirflowFileParseException method) (airflow.exceptions.FileSyntaxError method) (airflow.models.dag.InconsistentDataInterval method) (airflow.models.param.NoValueSentinel 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.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.taskreschedule.TaskReschedule 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.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.taskreschedule.TaskReschedule attribute) (airflow.models.trigger.Trigger attribute) (airflow.models.variable.Variable attribute) (airflow.models.xcom.BaseXCom attribute)

A

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_only_new() (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) 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.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.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.errors module airflow.models.log 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.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.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.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.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 AirflowException AirflowFailException AirflowFileParseException AirflowKubernetesScheduler (class in airflow.executors.kubernetes_executor) AirflowNotFoundException 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) ApiClient (in module airflow.models.taskinstance) app (in module airflow.executors.celery_executor) are_dependencies_met() (airflow.models.taskinstance.TaskInstance method) are_dependents_done() (airflow.models.taskinstance.TaskInstance 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) BashOperator (class in airflow.operators.bash)

BashSensor (class in airflow.sensors.bash) BLUE (airflow.operators.python.PythonOperator attribute) 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) 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) 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) 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) 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) create_dagrun() (airflow.models.dag.DAG method) create_new_task_handler() (airflow.sensors.smart_sensor.SensorWork static method) create_or_update_pool() (airflow.models.pool.Pool static method) create_timetable() (in module airflow.models.dag) created_at (airflow.models.sensorinstance.SensorInstance 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)

D

dag (airflow.models.baseoperator.BaseOperator property) (airflow.models.dagrun.DagRun attribute) (airflow.models.serialized_dag.SerializedDagModel property) DAG (class in airflow.models.dag) dag() (in module airflow.models.dag) 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.baseoperator.BaseOperator 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.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (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_num (airflow.models.dagbag.FileLoadStat attribute) dag_run (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) dag_runs (airflow.models.serialized_dag.SerializedDagModel attribute) DagBag (class in airflow.models.dagbag) DAGBAG_IMPORT_TIMEOUT (airflow.models.dagbag.DagBag attribute) 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) 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 attribute) 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) 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) 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_POOL_NAME (airflow.models.pool.Pool attribute) DEFAULT_SCHEDULE_INTERVAL (in module airflow.models.dag) DEFAULT_SECRETS_SEARCH_PATH (in module airflow.secrets) default_view (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) DEFAULT_VIEW_PRESETS (in module airflow.models.dag) defer() (airflow.models.baseoperator.BaseOperator method) 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) deps (airflow.models.baseoperator.BaseOperator attribute) (airflow.sensors.base.BaseSensorOperator property) 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) deserialize() (airflow.timetables.base.Timetable class method) (airflow.timetables.interval.CronDataIntervalTimetable class method) (airflow.timetables.interval.DeltaDataIntervalTimetable class method) deserialize_value() (airflow.models.xcom.BaseXCom static method) determine_kwargs() (airflow.operators.python.PythonOperator method) (airflow.operators.python.PythonVirtualenvOperator method) 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) downstream_list (airflow.models.baseoperator.BaseOperator property) downstream_task_ids (airflow.models.baseoperator.BaseOperator property) 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) 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) email_alert() (airflow.models.taskinstance.TaskInstance method) email_sent (airflow.models.slamiss.SlaMiss attribute) EmailOperator (class in airflow.operators.email) 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.sequential_executor.SequentialExecutor method) end_date (airflow.models.dagrun.DagRun attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskreschedule.TaskReschedule attribute) environment variable AIRFLOW__{SECTION}__{KEY}, [1], [2] AIRFLOW__{SECTION}__{KEY}_CMD AIRFLOW__{SECTION}__{KEY}_SECRET AIRFLOW_CONFIG, [1] AIRFLOW_CONN_{CONN_ID}, [1], [2] AIRFLOW_HOME, [1] AIRFLOW_VAR_{KEY}, [1] AIRFLOW_VAR_{VARIABLE_NAME} FLASK_APP PYTHONPATH, [1], [2], [3], [4], [5], [6], [7], [8], [9] EnvironmentVariablesBackend (class in airflow.secrets.environment_variables) error() (airflow.models.taskinstance.TaskInstance method) event (airflow.models.log.Log attribute) EventBufferValueType (in module airflow.executors.base_executor) 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.models.baseoperator.BaseOperator method) (airflow.operators.bash.BashOperator method) (airflow.operators.branch.BaseBranchOperator method) (airflow.operators.dummy.DummyOperator method) (airflow.operators.email.EmailOperator 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.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.celery_executor.CeleryExecutor 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.taskfail.TaskFail attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) execution_fields (airflow.sensors.base.BaseSensorOperator attribute) executor_config (airflow.models.taskinstance.SimpleTaskInstance 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) 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.baseoperator.BaseOperator 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) 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_tasks (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_object() (airflow.models.trigger.Trigger 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) 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_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_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.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.dagbag.DagBag method) (airflow.models.dagrun.DagRun method) get_dag_dependencies() (airflow.models.serialized_dag.SerializedDagModel class method) get_dagmodel() (airflow.models.dag.DagModel static method) get_dagrun() (airflow.models.dag.DAG method) (airflow.models.taskinstance.TaskInstance method) get_dagruns_between() (airflow.models.dag.DAG method) get_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.baseoperator.BaseOperator method) get_direct_relatives() (airflow.models.baseoperator.BaseOperator 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) get_execution_context() (airflow.sensors.base.BaseSensorOperator method) get_extra() (airflow.models.connection.Connection method) get_extra_links() (airflow.models.baseoperator.BaseOperator 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.baseoperator.BaseOperator method) get_flat_relatives() (airflow.models.baseoperator.BaseOperator 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) 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_many() (airflow.executors.celery_executor.BulkStateFetcher method) get_max_last_updated_datetime() (airflow.models.serialized_dag.SerializedDagModel class method) 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_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.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.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) get_templated_fields() (airflow.models.renderedtifields.RenderedTaskInstanceFields class method) get_truncated_error_traceback() (airflow.models.taskinstance.TaskInstance method) get_ui_field_behaviour() (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_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.baseoperator.BaseOperator 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) 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.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) 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.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.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) ImportError (class in airflow.models.errors) InconsistentDataInterval infer_automated_data_interval() (airflow.models.dag.DAG method) infer_manual_data_interval() (airflow.timetables.base.Timetable method) (airflow.timetables.interval.CronDataIntervalTimetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) inherits_from_dummy_operator (airflow.models.baseoperator.BaseOperator property) (airflow.operators.dummy.DummyOperator attribute) init_on_load() (airflow.models.taskinstance.TaskInstance method) (airflow.models.xcom.BaseXCom method) init_run_context() (airflow.models.taskinstance.TaskInstance 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_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.DagModel attribute) iter_dagrun_infos_between() (airflow.models.dag.DAG method)

J

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

K

k8s_pod_yaml (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) key (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance property) (airflow.models.taskinstance.TaskInstanceKey property) (airflow.models.variable.Variable attribute) (airflow.models.xcom.BaseXCom attribute) (airflow.models.xcom_arg.XComArg property)

KUBERNETES_EXECUTOR (in module airflow.executors.executor_constants) KUBERNETES_QUEUE (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor 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.trigger.Trigger attribute)

L

last_expired (airflow.models.dag.DagModel attribute) last_parsed_time (airflow.models.dag.DagModel attribute) last_pickled (airflow.models.dag.DagModel attribute) last_scheduling_decision (airflow.models.dagrun.DagRun attribute) 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) LatestOnlyOperator (class in airflow.operators.latest_only) leaves (airflow.models.baseoperator.BaseOperator property) (airflow.models.dag.DAG property) (airflow.models.taskmixin.TaskMixin property) (airflow.models.xcom_arg.XComArg property) line_no (airflow.exceptions.FileSyntaxError 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) 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) LocalWorker (class in airflow.executors.local_executor) LocalWorkerBase (class in airflow.executors.local_executor) Log (class in airflow.models.log) log (in module airflow.executors.celery_executor) (in module airflow.executors.executor_loader) (in module airflow.hooks.base) (in module airflow.models.connection) (in module airflow.models.crypto) (in module airflow.models.dag) (in module airflow.models.dagcode) (in module airflow.models.serialized_dag) (in module airflow.models.taskinstance) (in module airflow.models.variable) (in module airflow.models.xcom) (in module airflow.secrets.local_filesystem) log_info() (airflow.models.connection.Connection method) log_url (airflow.models.taskinstance.TaskInstance property) logical_date (airflow.models.dagrun.DagRun property) (airflow.timetables.base.DagRunInfo property) login (airflow.models.connection.Connection attribute)

M

Major release 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_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.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.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.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.errors airflow.models.log 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.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.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.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.interval airflow.timetables.simple

MsSqlToHiveTransfer (class in airflow.operators.mssql_to_hive) MySqlToHiveTransfer (class in airflow.operators.mysql_to_hive)

N

name (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.models.dag.DAG method) (airflow.timetables.base.Timetable 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 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) NoValueSentinel (class in airflow.models.param) 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_kill() (airflow.models.baseoperator.BaseOperator method) (airflow.operators.bash.BashOperator method) (airflow.sensors.smart_sensor.SmartSensorOperator method) 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) (airflow.models.xcom_arg.XComArg property)

Operator (class in airflow.models.base) operator_extra_link_dict() (airflow.models.baseoperator.BaseOperator method) operator_extra_links (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.trigger_dagrun.TriggerDagRunOperator property) (airflow.sensors.external_task.ExternalTaskSensor property) 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) output (airflow.models.baseoperator.BaseOperator property) overwrite_params_with_dag_run_conf() (airflow.models.taskinstance.TaskInstance method) owner (airflow.models.dag.DAG property) (airflow.models.log.Log attribute) 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) ParamsDict (class in airflow.models.param) parent_dag (airflow.models.dag.DagModel attribute) parse_from_uri() (airflow.models.connection.Connection method) parse_netloc_to_hostname() (in module airflow.models.connection) 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) 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) pool (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.pool.Pool attribute) (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute)

Pool (class in airflow.models.pool) pool_slots (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.sensors.base.BaseSensorOperator method) prepare_template() (airflow.models.baseoperator.BaseOperator 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) 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) priority_weight (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute) priority_weight_total (airflow.models.baseoperator.BaseOperator 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) push() (airflow.operators.sql.SQLThresholdCheckOperator method) 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.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute) queue_command() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) queue_task_instance() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.executors.debug_executor.DebugExecutor 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) 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.baseoperator.BaseOperator method) render_template_fields() (airflow.models.baseoperator.BaseOperator method) render_templates() (airflow.models.taskinstance.TaskInstance method) rendered_fields (airflow.models.renderedtifields.RenderedTaskInstanceFields 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.baseoperator.BaseOperator method) (airflow.models.dag.DAG method)

resolve_xcom_backend() (in module airflow.models.xcom) resource_version (airflow.executors.kubernetes_executor.ResourceVersion attribute) ResourceVersion (class in airflow.executors.kubernetes_executor) root_dag_id (airflow.models.dag.DagModel attribute) roots (airflow.models.baseoperator.BaseOperator property) (airflow.models.dag.DAG property) (airflow.models.taskmixin.TaskMixin 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_command() (airflow.hooks.subprocess.SubprocessHook method) run_id (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey 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_type (airflow.models.dagrun.DagRun attribute) running (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor 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) ScheduleIntervalArgNotSet (in module airflow.models.dag) scheduler_lock (airflow.models.dag.DagModel attribute) SCHEDULER_ZOMBIE_TASK_THRESHOLD (airflow.models.dagbag.DagBag attribute) schema (airflow.models.connection.Connection attribute) 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.interval.CronDataIntervalTimetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable 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.baseoperator.BaseOperator method) (airflow.models.taskmixin.TaskMixin 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.baseoperator.BaseOperator method) (airflow.models.taskmixin.TaskMixin 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) 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) 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) slots_stats() (airflow.models.pool.Pool static method) SmartSensorOperator (class in airflow.sensors.smart_sensor) 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) 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) start_date (airflow.models.dagrun.DagRun attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskreschedule.TaskReschedule attribute) state (airflow.models.dagrun.DagRun property) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute) status_code (airflow.exceptions.AirflowBadRequest attribute) (airflow.exceptions.AirflowException attribute) (airflow.exceptions.AirflowNotFoundException attribute) store_serialized_dags (airflow.models.dagbag.DagBag property) sub_dag() (airflow.models.dag.DAG method) 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.interval.CronDataIntervalTimetable property) (airflow.timetables.interval.DeltaDataIntervalTimetable property) (airflow.timetables.simple.NullTimetable property) (airflow.timetables.simple.OnceTimetable property) 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) tags (airflow.models.dag.DagModel attribute) target_times_as_dates() (in module airflow.operators.datetime) task (airflow.models.dag.DAG property) task() (in module airflow.operators.python) task_group (airflow.models.dag.DAG property) task_id (airflow.models.log.Log attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) task_ids (airflow.models.dag.DAG property) task_instance_scheduling_decisions() (airflow.models.dagrun.DagRun method) task_instances (airflow.models.dagrun.DagRun attribute) task_num (airflow.models.dagbag.FileLoadStat attribute) task_type (airflow.models.baseoperator.BaseOperator property) 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) 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.baseoperator) template_ext (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.bash.BashOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.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.baseoperator.BaseOperator attribute) (airflow.operators.bash.BashOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.python.PythonOperator attribute) (airflow.operators.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.operators.bash.BashOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.python.PythonOperator attribute) (airflow.operators.sql.SQLIntervalCheckOperator 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.sequential_executor.SequentialExecutor method) test_connection() (airflow.hooks.dbapi.DbApiHook method) (airflow.models.connection.Connection method) ThresholdCheckOperator (class in airflow.operators.check_operator) ti_key (airflow.sensors.smart_sensor.SensorWork property) 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) 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_id (airflow.models.taskinstance.TaskInstance attribute) trigger_tasks() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_executor.CeleryExecutor 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) try_number (airflow.models.sensorinstance.SensorInstance property) (airflow.models.taskinstance.SimpleTaskInstance property) (airflow.models.taskinstance.TaskInstance property) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskreschedule.TaskReschedule attribute)

U

ui_color (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.bash.BashOperator attribute) (airflow.operators.dummy.DummyOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.latest_only.LatestOnlyOperator attribute) (airflow.operators.python.PythonOperator 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.operators.sql.BranchSQLOperator attribute) (airflow.operators.subdag.SubDagOperator attribute) unfinished_tasks (airflow.models.dagrun.TISchedulingDecision attribute) unixname (airflow.models.taskinstance.TaskInstance attribute) 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.TaskMixin 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.baseoperator.BaseOperator property) upstream_task_ids (airflow.models.baseoperator.BaseOperator property)

V

val (airflow.models.variable.Variable property) valid_modes (airflow.sensors.base.BaseSensorOperator attribute) validate() (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_schedule_and_params() (airflow.models.dag.DAG method) value (airflow.models.xcom.BaseXCom attribute) ValueCheckOperator (class in airflow.operators.check_operator) VAR_ENV_PREFIX (in module airflow.secrets.environment_variables) Variable (class in airflow.models.variable) verify_integrity() (airflow.models.dagrun.DagRun method)

W

with_try_number() (airflow.models.taskinstance.TaskInstanceKey method)

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)

PreviousNext

Was this entry helpful?