• Home
• Index

Index

_

__deepcopy__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.operators.python.PythonVirtualenvOperator method) __enter__() (airflow.models.DAG method) (airflow.models.dag.DAG method) __eq__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG 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 method) (airflow.models.dag.DAG method) __getitem__() (airflow.models.param.ParamsDict method) (airflow.models.xcom_arg.XComArg method) __getstate__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) __gt__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) __hash__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) __lshift__() (airflow.models.taskmixin.TaskMixin method) __lt__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) __mapper_args__ (airflow.operators.sql.SQLIntervalCheckOperator attribute) (airflow.operators.sql.SQLValueCheckOperator attribute) __ne__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) __new__() (airflow.executors.kubernetes_executor.ResourceVersion class method) (airflow.models.baseoperator.BaseOperatorMeta class method) __or__() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) __repr__() (airflow.exceptions.TaskDeferred method) (airflow.executors.base_executor.BaseExecutor method) (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.Connection method) (airflow.models.connection.Connection method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (airflow.models.dag.DagTag method) (airflow.models.DagModel method) (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) (airflow.models.DagTag method) (airflow.models.Pool method) (airflow.models.pool.Pool method) (airflow.models.RenderedTaskInstanceFields method) (airflow.models.renderedtifields.RenderedTaskInstanceFields method) (airflow.models.SensorInstance method) (airflow.models.sensorinstance.SensorInstance method) (airflow.models.serialized_dag.SerializedDagModel method) (airflow.models.SlaMiss method) (airflow.models.slamiss.SlaMiss method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.models.Variable 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 method) (airflow.models.baseoperator.BaseOperator method) __setitem__() (airflow.models.param.ParamsDict method) __setstate__() (airflow.models.BaseOperator method) (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.xcom_arg.XComArg method) __table_args__ (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) __tablename__ (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) (airflow.models.dag.DagModel attribute) (airflow.models.dag.DagTag attribute) (airflow.models.dagcode.DagCode attribute) (airflow.models.DagModel attribute) (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.DagTag attribute) (airflow.models.errors.ImportError attribute) (airflow.models.ImportError attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) (airflow.models.RenderedTaskInstanceFields attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.Trigger attribute) (airflow.models.trigger.Trigger attribute) (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) (airflow.models.xcom.BaseXCom attribute)

A

access_control (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) add_inlets() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) add_only_new() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) add_outlets() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) add_task() (airflow.models.DAG method) (airflow.models.dag.DAG method) add_tasks() (airflow.models.DAG method) (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 attribute) (airflow.models.dag.DAG attribute) ANY_LEAF (airflow.operators.subdag.SkippedStatePropagationOptions attribute) ApiClient (in module airflow.models.taskinstance) app (in module airflow.executors.celery_executor) apply_defaults (in module airflow.sensors.base) are_dependencies_met() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) are_dependents_done() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) assign_unassigned() (airflow.models.Trigger class method) (airflow.models.trigger.Trigger class method)

B

BackfillUnfinished bag_dag() (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) Base (in module airflow.models) (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) (class in airflow.models.baseoperator) BaseOperatorLink (class in airflow.models) (class in airflow.models.baseoperator) BaseOperatorMeta (class in airflow.models.baseoperator) BaseSecretsBackend (class in airflow.secrets) (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) (airflow.secrets.BaseSecretsBackend static method) bulk_dump() (airflow.hooks.dbapi.DbApiHook method) bulk_fetch() (airflow.models.Trigger class method) (airflow.models.trigger.Trigger class method) bulk_load() (airflow.hooks.dbapi.DbApiHook method) bulk_sync_to_db() (airflow.models.DAG class method) (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 class method) (airflow.models.dag.DAG class method) BulkStateFetcher (class in airflow.executors.celery_executor)

C

cache_key (airflow.sensors.smart_sensor.SensorWork attribute) CachedPokeWork (class in airflow.sensors.smart_sensor) calculate_dagrun_date_fields() (airflow.models.dag.DagModel method) (airflow.models.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 method) (airflow.models.taskinstance.TaskInstance method) check_for_write_conflict() (airflow.models.Variable method) (airflow.models.variable.Variable 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) classpath (airflow.models.Trigger attribute) (airflow.models.trigger.Trigger attribute) clean_unused() (airflow.models.Trigger class method) (airflow.models.trigger.Trigger class method) clear() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.xcom.BaseXCom class method) clear_dags() (airflow.models.DAG class method) (airflow.models.dag.DAG class 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) (in module airflow.models.taskinstance) clear_xcom_data() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) cli() (airflow.models.DAG method) (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 method) (airflow.models.dagbag.DagBag method) collect_dags_from_db() (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) command_as_list() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) CommandType (in module airflow.executors.base_executor) concurrency (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) concurrency_reached (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) conf (airflow.models.DagRun attribute) (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 attribute) (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 attribute) (airflow.models.connection.Connection attribute) connect() (airflow.hooks.dbapi.ConnectorProtocol method) Connection (class in airflow.models) (class in airflow.models.connection) ConnectionNotUnique connector (airflow.hooks.dbapi.DbApiHook attribute) ConnectorProtocol (class in airflow.hooks.dbapi) Context (in module airflow.models.taskinstance) create_dagrun() (airflow.models.DAG method) (airflow.models.dag.DAG method) create_new_task_handler() (airflow.sensors.smart_sensor.SensorWork static method) create_timetable() (in module airflow.models.dag) created_at (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) created_date (airflow.models.Trigger attribute) (airflow.models.trigger.Trigger attribute) created_dttm (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) creating_job_id (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) CronDataIntervalTimetable (class in airflow.timetables.interval) cross_downstream() (in module airflow.models.baseoperator) current_state() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method)

D

dag (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) DAG (class in airflow.models) (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 attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) dag_id (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.dag.DagTag attribute) (airflow.models.DagModel attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.DagTag attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.RenderedTaskInstanceFields attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.serialized_dag.SerializedDagModel attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) dag_ids (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) dag_model (airflow.models.serialized_dag.SerializedDagModel attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) dag_num (airflow.models.dagbag.FileLoadStat attribute) dag_run (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) dag_runs (airflow.models.serialized_dag.SerializedDagModel attribute) DagBag (class in airflow.models) (class in airflow.models.dagbag) DAGBAG_IMPORT_TIMEOUT (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) dagbag_report() (airflow.models.DagBag method) (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) (class in airflow.models.dag) DagNotFound DagParam (class in airflow.models.param) DagPickle (class in airflow.models) (class in airflow.models.dagpickle) DagRun (class in airflow.models) (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) (airflow.models.DagModel class method) DagStateChangeCallback (in module airflow.models.dag) DagTag (class in airflow.models) (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 attribute) (airflow.models.dagrun.DagRun attribute) data_interval_start (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) DataInterval (class in airflow.timetables.base) date_range() (airflow.models.DAG method) (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) (airflow.models.DagModel class method) deactivate_stale_dags() (airflow.models.DAG static method) (airflow.models.dag.DAG static method) deactivate_unknown_dags() (airflow.models.DAG static method) (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 method) (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 attribute) (airflow.models.dagrun.DagRun attribute) DEFAULT_POOL_NAME (airflow.models.Pool attribute) (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 attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) DEFAULT_VIEW_PRESETS (in module airflow.models.dag) defer() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) delete() (airflow.models.Variable class method) (airflow.models.variable.Variable class method) (airflow.models.xcom.BaseXCom class method) delete_old_records() (airflow.models.RenderedTaskInstanceFields class method) (airflow.models.renderedtifields.RenderedTaskInstanceFields class method) delete_pod() (airflow.executors.kubernetes_executor.AirflowKubernetesScheduler method) Delta (in module airflow.timetables.interval) DeltaDataIntervalTimetable (class in airflow.timetables.interval) deps (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.sensors.base.BaseSensorOperator attribute) description (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.Variable 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) 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 attribute) (airflow.models.baseoperator.BaseOperator attribute) downstream_task_ids (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) dry_run() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) ds_add() (in module airflow.macros) ds_format() (in module airflow.macros) dttm (airflow.models.Log attribute) (airflow.models.log.Log attribute) DummyOperator (class in airflow.operators.dummy) dump() (airflow.models.Param method) (airflow.models.param.Param method) (airflow.models.param.ParamsDict method) DuplicateTaskIdFound duration (airflow.models.dagbag.FileLoadStat attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute)

E

earliest (airflow.timetables.base.TimeRestriction attribute) email_alert() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) email_sent (airflow.models.SlaMiss attribute) (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 attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule 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 method) (airflow.models.taskinstance.TaskInstance method) event (airflow.models.Log attribute) (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 attribute) ExceptionWithTraceback (class in airflow.executors.celery_executor) execute() (airflow.models.BaseOperator method) (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 attribute) (airflow.models.sensorinstance.SensorInstance attribute) execution_date (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.RenderedTaskInstanceFields attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) execution_fields (airflow.sensors.base.BaseSensorOperator attribute) executor_config (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (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 attribute) (airflow.models.taskinstance.TaskInstance attribute) external_trigger (airflow.models.DagRun attribute) (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 attribute) (airflow.models.connection.Connection attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) extra_dejson (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) EXTRA_KEY (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) extra_links() (airflow.models.BaseOperator method) (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 attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.dagcode.DagCode attribute) (airflow.models.DagModel 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.ImportError attribute) filepath (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) FileSensor (class in airflow.sensors.filesystem)

FileSyntaxError (class in airflow.exceptions) filter_for_tis() (airflow.models.TaskInstance static method) (airflow.models.taskinstance.TaskInstance static method) find() (airflow.models.DagRun static method) (airflow.models.dagrun.DagRun static method) find_for_task_instance() (airflow.models.TaskReschedule static method) (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 attribute) (airflow.models.dag.DAG attribute) following_schedule() (airflow.models.DAG method) (airflow.models.dag.DAG method) formatter_config (in module airflow.sensors.smart_sensor) from_object() (airflow.models.Trigger class method) (airflow.models.trigger.Trigger class method) FSHook (class in airflow.hooks.filesystem) full_filepath (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute)

G

generate_command() (airflow.models.TaskInstance static method) (airflow.models.taskinstance.TaskInstance static method) generate_run_id() (airflow.models.DagRun static method) (airflow.models.dagrun.DagRun static method) GenericTransfer (class in airflow.operators.generic_transfer) get() (airflow.models.serialized_dag.SerializedDagModel class method) (airflow.models.Variable class method) (airflow.models.variable.Variable class method) get_active_runs() (airflow.models.DAG method) (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 static method) (airflow.models.sensorinstance.SensorInstance static method) get_code_by_fileloc() (airflow.models.dagcode.DagCode class method) get_concurrency_reached() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_config() (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.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.BaseSecretsBackend method) (airflow.secrets.environment_variables.EnvironmentVariablesBackend method) get_connection() (airflow.hooks.base.BaseHook class method) (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.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 class method) (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.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) (airflow.models.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 method) (airflow.models.dagbag.DagBag method) (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_dag_dependencies() (airflow.models.serialized_dag.SerializedDagModel class method) get_dagmodel() (airflow.models.dag.DagModel static method) (airflow.models.DagModel static method) get_dagrun() (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_dagruns_between() (airflow.models.DAG method) (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 static method) (airflow.models.pool.Pool static method) get_default_view() (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (airflow.models.DagModel method) get_direct_relative_ids() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) get_direct_relatives() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) get_edge_info() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_email_subject_content() (airflow.models.TaskInstance method) (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 method) (airflow.models.connection.Connection method) get_extra_links() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) get_failed_dep_statuses() (airflow.models.TaskInstance method) (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 method) (airflow.models.baseoperator.BaseOperator method) get_flat_relatives() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) get_hook() (airflow.hooks.base.BaseHook class method) (airflow.models.Connection method) (airflow.models.connection.Connection method) get_id_collation_args() (in module airflow.models.base) get_inlet_defs() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) get_is_active() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_is_paused() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_k8s_pod_yaml() (airflow.models.RenderedTaskInstanceFields class method) (airflow.models.renderedtifields.RenderedTaskInstanceFields class method) get_last_dagrun() (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (airflow.models.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 method) (airflow.models.dag.DAG method) get_latest_runs() (airflow.models.DagRun class method) (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.models.BaseOperatorLink method) (airflow.operators.trigger_dagrun.TriggerDagRunLink method) (airflow.sensors.external_task.ExternalTaskSensorLink method) get_many() (airflow.executors.celery_executor.BulkStateFetcher method) (airflow.models.xcom.BaseXCom class method) get_max_last_updated_datetime() (airflow.models.serialized_dag.SerializedDagModel class method) get_next_data_interval() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_num_active_runs() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_num_running_task_instances() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_num_task_instances() (airflow.models.DAG static method) (airflow.models.dag.DAG static method) get_one() (airflow.models.xcom.BaseXCom class method) get_outlet_defs() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) get_pandas_df() (airflow.hooks.dbapi.DbApiHook method) get_password() (airflow.models.Connection method) (airflow.models.connection.Connection method) get_path() (airflow.hooks.filesystem.FSHook method) get_paused_dag_ids() (airflow.models.dag.DagModel static method) (airflow.models.DagModel static method) get_poke_context() (airflow.sensors.base.BaseSensorOperator method) get_pool() (airflow.models.Pool static method) (airflow.models.pool.Pool static method) get_previous_dagrun() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_previous_execution_date() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_previous_scheduled_dagrun() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_previous_start_date() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_previous_ti() (airflow.models.TaskInstance method) (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 method) (airflow.models.taskinstance.TaskInstance method) get_rendered_template_fields() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_run() (airflow.models.DagRun static method) (airflow.models.dagrun.DagRun static method) get_run_data_interval() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_run_dates() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_serialized_fields() (airflow.models.BaseOperator class method) (airflow.models.baseoperator.BaseOperator class method) (airflow.models.DAG 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 method) (airflow.models.dagrun.DagRun method) get_task() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_task_instance() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_task_instances() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) get_task_instances_before() (airflow.models.DAG method) (airflow.models.dag.DAG method) get_template_context() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) get_template_env() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) get_templated_fields() (airflow.models.RenderedTaskInstanceFields class method) (airflow.models.renderedtifields.RenderedTaskInstanceFields class method) get_ui_field_behaviour() (airflow.hooks.base.DiscoverableHook static method) get_uri() (airflow.hooks.dbapi.DbApiHook method) (airflow.models.Connection method) (airflow.models.connection.Connection method) get_val() (airflow.models.Variable method) (airflow.models.variable.Variable method) get_variable() (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.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 static method) (airflow.models.variable.Variable static method) global_operator_extra_link_dict() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) GoogleApiToS3Transfer (class in airflow.operators.google_api_to_s3_transfer)

H

handle_callback() (airflow.models.DAG method) (airflow.models.dag.DAG method) handle_failure() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) handle_failure_with_callback() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) handler_config (in module airflow.sensors.smart_sensor) has_dag() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.dagcode.DagCode class method) (airflow.models.serialized_dag.SerializedDagModel class method) has_dag_runs() (airflow.models.DAG method) (airflow.models.dag.DAG method) has_task() (airflow.executors.base_executor.BaseExecutor method) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor method) (airflow.models.DAG method) (airflow.models.dag.DAG method)

has_task_concurrency_limits (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) hashcode (airflow.models.SensorInstance attribute) (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 attribute) (airflow.models.connection.Connection attribute) hostname (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute)

I

id (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.errors.ImportError attribute) (airflow.models.ImportError attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.Trigger attribute) (airflow.models.trigger.Trigger attribute) (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) ID_LEN (in module airflow.models) (in module airflow.models.base) ids_for_triggerer() (airflow.models.Trigger class method) (airflow.models.trigger.Trigger class method) ImportError (class in airflow.models) (class in airflow.models.errors) InconsistentDataInterval infer_automated_data_interval() (airflow.models.DAG method) (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 attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.dummy.DummyOperator attribute) init_on_load() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.models.xcom.BaseXCom method)

init_run_context() (airflow.models.TaskInstance method) (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) (airflow.models.DagModel attribute) is_backfill (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) is_eligible_to_retry() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) is_encrypted (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) (airflow.models.crypto.NullFernet attribute) (airflow.models.Variable 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 attribute) (airflow.models.connection.Connection attribute) is_fixed_time_schedule() (airflow.models.DAG method) (airflow.models.dag.DAG method) is_infra_failure (airflow.sensors.smart_sensor.SensorExceptionInfo attribute) is_paused (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) is_paused_at_creation (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) is_premature (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) is_smart_sensor_compatible() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.sensors.base.BaseSensorOperator method) is_subdag (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) iter_dagrun_infos_between() (airflow.models.DAG method) (airflow.models.dag.DAG method)

J

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

K

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

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 attribute) (airflow.models.trigger.Trigger attribute)

L

last_expired (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) last_parsed_time (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) last_pickled (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) last_scheduling_decision (airflow.models.DagRun attribute) (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 attribute) (airflow.models.dag.DAG attribute) LatestOnlyOperator (class in airflow.operators.latest_only) leaves (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.taskmixin.TaskMixin attribute) (airflow.models.xcom_arg.XComArg attribute) 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) (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 method) (airflow.models.connection.Connection method) log_url (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) logical_date (airflow.timetables.base.DagRunInfo attribute) login (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute)

M

Major release mark_success_url (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) max_active_runs (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) max_active_tasks (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) max_partition() (in module airflow.macros.hive) max_tries (airflow.models.TaskInstance attribute) (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 attribute) (airflow.models.BaseOperatorLink attribute) (airflow.models.dag.DagTag attribute) (airflow.models.DagTag attribute) (airflow.operators.trigger_dagrun.TriggerDagRunLink attribute) (airflow.sensors.external_task.ExternalTaskSensorLink attribute) next_dagrun (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) next_dagrun_after_date() (airflow.models.DAG method) (airflow.models.dag.DAG method) next_dagrun_create_after (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) next_dagrun_data_interval (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) next_dagrun_data_interval_end (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) next_dagrun_data_interval_start (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) next_dagrun_info() (airflow.models.DAG method) (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 class method) (airflow.models.dagrun.DagRun class method) next_kwargs (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) next_method (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) next_retry_datetime() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) next_try_number (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) NoAvailablePoolSlot normalize_schedule() (airflow.models.DAG method) (airflow.models.dag.DAG method) normalized_schedule_interval (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) NOT_STARTED_MESSAGE (in module airflow.executors.base_executor) notification_sent (airflow.models.SlaMiss attribute) (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) (airflow.models.DagModel attribute)

O

occupied_slots() (airflow.models.Pool method) (airflow.models.pool.Pool method) on_celery_import_modules() (in module airflow.executors.celery_executor) on_db_load() (airflow.models.Connection method) (airflow.models.connection.Connection method) (airflow.models.Variable method) (airflow.models.variable.Variable method) on_kill() (airflow.models.BaseOperator method) (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 attribute) (airflow.models.sensorinstance.SensorInstance attribute) open (airflow.models.pool.PoolStats attribute) open_slots() (airflow.models.Pool method) (airflow.models.pool.Pool method) OPERATION_TIMEOUT (in module airflow.executors.celery_executor) operator (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.xcom_arg.XComArg attribute)

Operator (class in airflow.models.base) operator_extra_link_dict() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) operator_extra_links (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.sensors.external_task.ExternalTaskSensor attribute) operators (airflow.models.baseoperator.BaseOperatorLink attribute) (airflow.models.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 attribute) (airflow.models.baseoperator.BaseOperator attribute) overwrite_params_with_dag_run_conf() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) owner (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.Log attribute) (airflow.models.log.Log attribute) owners (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute)

P

PARALLELISM (in module airflow.executors.base_executor) Param (class in airflow.models) (class in airflow.models.param) param() (airflow.models.DAG method) (airflow.models.dag.DAG method) ParamsDict (class in airflow.models.param) parent_dag (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) parse_from_uri() (airflow.models.Connection method) (airflow.models.connection.Connection method) parse_netloc_to_hostname() (in module airflow.models.connection) partial_subset() (airflow.models.DAG method) (airflow.models.dag.DAG method) password (airflow.models.Connection attribute) (airflow.models.connection.Connection attribute) Patch releases PENDULUM_SERIALIZABLE_CONTEXT_KEYS (airflow.operators.python.PythonVirtualenvOperator attribute) periodic (airflow.timetables.base.Timetable attribute) pickle (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) pickle() (airflow.models.DAG method) (airflow.models.dag.DAG method) pickle_hash (airflow.models.DagPickle attribute) (airflow.models.dagpickle.DagPickle attribute) pickle_id (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) pickle_info() (airflow.models.DAG method) (airflow.models.dag.DAG method) pid (airflow.models.TaskInstance attribute) (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 attribute) (airflow.models.sensorinstance.SensorInstance attribute) poke_mode_only() (in module airflow.sensors.base) pool (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute)

Pool (class in airflow.models) (class in airflow.models.pool) pool_slots (airflow.models.TaskInstance attribute) (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 attribute) (airflow.models.connection.Connection attribute) post_execute() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.subdag.SubDagOperator method) pre_execute() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.subdag.SubDagOperator method) prepare_for_execution() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.sensors.base.BaseSensorOperator method) prepare_template() (airflow.models.BaseOperator method) (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 attribute) (airflow.models.taskinstance.TaskInstance attribute) previous_schedule() (airflow.models.DAG method) (airflow.models.dag.DAG method) previous_start_date_success (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) previous_ti (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) previous_ti_success (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) primary (airflow.models.taskinstance.TaskInstanceKey attribute) priority_weight (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) priority_weight_total (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) process_error() (airflow.executors.kubernetes_executor.KubernetesJobWatcher method) process_file() (airflow.models.DagBag method) (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 static method) (airflow.models.taskreschedule.TaskReschedule static method) queue (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (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 attribute) (airflow.models.dagrun.DagRun attribute) queued_by_job (in module airflow.models.taskinstance) queued_by_job_id (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) queued_dttm (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) queued_slots() (airflow.models.Pool method) (airflow.models.pool.Pool method) queued_tasks (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) QueuedLocalWorker (class in airflow.executors.local_executor) QueuedTaskInstanceType (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 method) (airflow.models.taskinstance.TaskInstance method) RedshiftToS3Transfer (class in airflow.operators.redshift_to_s3_operator) reduced (airflow.models.taskinstance.TaskInstanceKey attribute) refresh_from_db() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) refresh_from_task() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) register() (airflow.models.SensorInstance class method) (airflow.models.sensorinstance.SensorInstance class method) register_in_sensor_service() (airflow.sensors.base.BaseSensorOperator method) relative_fileloc (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) 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 method) (airflow.models.taskinstance.TaskInstance method) render_template() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) render_template_fields() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) render_templates() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) rendered_fields (airflow.models.RenderedTaskInstanceFields attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) RenderedTaskInstanceFields (class in airflow.models) (class in airflow.models.renderedtifields) reschedule (airflow.sensors.base.BaseSensorOperator attribute) reschedule_date (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) resolve() (airflow.models.Param method) (airflow.models.param.DagParam method) (airflow.models.param.Param method) (airflow.models.xcom_arg.XComArg method) resolve_template_files() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG 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) (airflow.models.DagModel attribute) roots (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) (airflow.models.taskmixin.TaskMixin attribute) (airflow.models.xcom_arg.XComArg attribute) rotate_fernet_key() (airflow.models.Connection method) (airflow.models.connection.Connection method) (airflow.models.Variable 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 method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.DAG method) (airflow.models.dag.DAG method) (airflow.models.TaskInstance 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 attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.TaskReschedule 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 attribute) (airflow.models.dagrun.DagRun attribute) running (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) (airflow.models.pool.PoolStats attribute) running_slots() (airflow.models.Pool method) (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 attribute) (airflow.models.DagModel attribute) schedulable_tis (airflow.models.dagrun.TISchedulingDecision attribute) schedule_interval (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) schedule_tis() (airflow.models.DagRun method) (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) (airflow.models.DagModel attribute) SCHEDULER_ZOMBIE_TASK_THRESHOLD (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) schema (airflow.models.Connection attribute) (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) (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) serialized_dag (in module airflow.models.dag) SerializedDagModel (class in airflow.models.serialized_dag) set() (airflow.models.Variable class method) (airflow.models.variable.Variable class method) (airflow.models.xcom.BaseXCom class method) set_autocommit() (airflow.hooks.dbapi.DbApiHook method) set_current_context() (in module airflow.models.taskinstance) set_dag_runs_state() (airflow.models.DAG method) (airflow.models.dag.DAG method) set_dependency() (airflow.models.DAG method) (airflow.models.dag.DAG method) set_downstream() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.taskmixin.TaskMixin method) (airflow.models.xcom_arg.XComArg method) set_duration() (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) set_edge_info() (airflow.models.DAG method) (airflow.models.dag.DAG method) set_error_file() (in module airflow.models.taskinstance) set_extra() (airflow.models.Connection method) (airflow.models.connection.Connection method) set_infra_failure_timeout() (airflow.sensors.smart_sensor.SensorExceptionInfo method) set_is_paused() (airflow.models.dag.DagModel method) (airflow.models.DagModel method) set_latest_exception() (airflow.sensors.smart_sensor.SensorExceptionInfo method) set_password() (airflow.models.Connection method) (airflow.models.connection.Connection method) set_state() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.sensors.smart_sensor.CachedPokeWork method) set_task_instance_state() (airflow.models.DAG method) (airflow.models.dag.DAG method) set_to_flush() (airflow.sensors.smart_sensor.CachedPokeWork method) set_upstream() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.taskmixin.TaskMixin method) (airflow.models.xcom_arg.XComArg method) set_val() (airflow.models.Variable method) (airflow.models.variable.Variable method) set_xcomargs_dependencies() (airflow.models.BaseOperator method) (airflow.models.baseoperator.BaseOperator method) setdefault() (airflow.models.Variable class method) (airflow.models.variable.Variable class method) shallow_copy_attrs (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.python.PythonOperator attribute) shardcode (airflow.models.SensorInstance attribute) (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 method) (airflow.models.dagbag.DagBag method) skip() (airflow.models.SkipMixin method) (airflow.models.skipmixin.SkipMixin method) skip_all_except() (airflow.models.SkipMixin method) (airflow.models.skipmixin.SkipMixin method)

SkipMixin (class in airflow.models) (class in airflow.models.skipmixin) SkippedStatePropagationOptions (class in airflow.operators.subdag) SlaMiss (class in airflow.models) (class in airflow.models.slamiss) slots (airflow.models.Pool attribute) (airflow.models.pool.Pool attribute) slots_available (airflow.executors.base_executor.BaseExecutor attribute) (airflow.executors.celery_kubernetes_executor.CeleryKubernetesExecutor attribute) slots_stats() (airflow.models.Pool static method) (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) (airflow.models.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 attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) state (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) STATICA_HACK (in module airflow.models.dag) (in module airflow.models.taskinstance) status_code (airflow.exceptions.AirflowBadRequest attribute) (airflow.exceptions.AirflowException attribute) (airflow.exceptions.AirflowNotFoundException attribute) store_serialized_dags (airflow.models.DagBag attribute) (airflow.models.dagbag.DagBag attribute) sub_dag() (airflow.models.DAG method) (airflow.models.dag.DAG method) SubDagOperator (class in airflow.operators.subdag) subdags (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) submit_event() (airflow.models.Trigger class method) (airflow.models.trigger.Trigger class method) submit_failure() (airflow.models.Trigger class method) (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 attribute) (airflow.timetables.interval.CronDataIntervalTimetable attribute) (airflow.timetables.interval.DeltaDataIntervalTimetable attribute) (airflow.timetables.simple.NullTimetable attribute) (airflow.timetables.simple.OnceTimetable attribute) supports_autocommit (airflow.hooks.dbapi.DbApiHook attribute) supports_lineage (airflow.models.BaseOperator attribute) (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 method) (airflow.models.dag.DAG method) (airflow.models.DagBag method) (airflow.models.dagbag.DagBag method) (airflow.models.dagcode.DagCode method)

T

T (in module airflow.models.baseoperator) tags (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) target_times_as_dates() (in module airflow.operators.datetime) task (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) task() (in module airflow.operators.python) task_group (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) task_id (airflow.models.Log attribute) (airflow.models.log.Log attribute) (airflow.models.RenderedTaskInstanceFields attribute) (airflow.models.renderedtifields.RenderedTaskInstanceFields attribute) (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.TaskFail attribute) (airflow.models.taskfail.TaskFail attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute) (airflow.models.xcom.BaseXCom attribute) task_ids (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) task_instance_scheduling_decisions() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method) task_instances (airflow.models.DagRun attribute) (airflow.models.dagrun.DagRun attribute) task_num (airflow.models.dagbag.FileLoadStat attribute) task_type (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) TaskConcurrencyLimitReached TaskDeferralError TaskDeferred TaskFail (class in airflow.models) (class in airflow.models.taskfail) TaskInstance (class in airflow.models) (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) (class in airflow.models.taskreschedule) tasks (airflow.models.DAG attribute) (airflow.models.dag.DAG attribute) TaskStateChangeCallback (in module airflow.models.baseoperator) template_ext (airflow.models.BaseOperator attribute) (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 attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.bash.BashOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.python.PythonOperator attribute) (airflow.operators.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 attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.bash.BashOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.python.PythonOperator attribute) (airflow.operators.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 method) (airflow.models.connection.Connection method) ThresholdCheckOperator (class in airflow.operators.check_operator) ti_key (airflow.sensors.smart_sensor.SensorWork attribute) 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.ImportError attribute) (airflow.models.SlaMiss attribute) (airflow.models.slamiss.SlaMiss attribute) (airflow.models.xcom.BaseXCom attribute) Timetable (class in airflow.timetables.base) timezone (airflow.models.dag.DagModel attribute) (airflow.models.DagModel attribute) tis (airflow.models.dagrun.TISchedulingDecision attribute) TISchedulingDecision (class in airflow.models.dagrun) to_json() (airflow.models.Pool method) (airflow.models.pool.Pool method) topological_sort() (airflow.models.DAG method) (airflow.models.dag.DAG method) total (airflow.models.pool.PoolStats attribute) TR (in module airflow.models.taskinstance) tree_view() (airflow.models.DAG method) (airflow.models.dag.DAG method) trigger (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) Trigger (class in airflow.models) (class in airflow.models.trigger) trigger_id (airflow.models.TaskInstance attribute) (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 attribute) (airflow.models.taskinstance.TaskInstance attribute) TriggerDagRunLink (class in airflow.operators.trigger_dagrun) TriggerDagRunOperator (class in airflow.operators.trigger_dagrun) triggerer_id (airflow.models.Trigger attribute) (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 attribute) (airflow.models.sensorinstance.SensorInstance attribute) (airflow.models.TaskInstance attribute) (airflow.models.taskinstance.SimpleTaskInstance attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.TaskReschedule attribute) (airflow.models.taskreschedule.TaskReschedule attribute)

U

ui_color (airflow.models.BaseOperator attribute) (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 attribute) (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 attribute) (airflow.models.taskinstance.TaskInstance attribute) UNPICKLEABLE_EXECUTORS (in module airflow.executors.executor_loader) update() (airflow.models.param.ParamsDict method) (airflow.models.Variable class 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 method) (airflow.models.dagrun.DagRun method) update_task_state() (airflow.executors.celery_executor.CeleryExecutor method) updated_at (airflow.models.SensorInstance attribute) (airflow.models.sensorinstance.SensorInstance attribute) upstream_list (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) upstream_task_ids (airflow.models.BaseOperator attribute) (airflow.models.baseoperator.BaseOperator attribute)

V

val (airflow.models.Variable attribute) (airflow.models.variable.Variable attribute) 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 method) (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) (class in airflow.models.variable) verify_integrity() (airflow.models.DagRun method) (airflow.models.dagrun.DagRun method)

W

with_try_number() (airflow.models.taskinstance.TaskInstanceKey method) write() (airflow.models.RenderedTaskInstanceFields method) (airflow.models.renderedtifields.RenderedTaskInstanceFields method)

write_dag() (airflow.models.serialized_dag.SerializedDagModel class method)

X

XCom (in module airflow.models) (in module airflow.models.xcom) xcom_pull() (airflow.models.BaseOperator static method) (airflow.models.baseoperator.BaseOperator static method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method) xcom_push() (airflow.models.BaseOperator static method) (airflow.models.baseoperator.BaseOperator static method) (airflow.models.TaskInstance method) (airflow.models.taskinstance.TaskInstance method)

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