• Home
• Index

Index

_

__attrs_post_init__() (airflow.decorators.base.DecoratedMappedOperator method) __bool__() (airflow.models.param.ParamsDict method) (airflow.sensors.base.PokeReturnValue method) __call__ (airflow.decorators.base.Task attribute) (airflow.decorators.TaskDecoratorCollection attribute) __call__() (airflow.decorators.base.TaskDecorator method) __contains__() (airflow.models.param.ParamsDict method) __copy__() (airflow.models.param.Param method) (airflow.models.param.ParamsDict method) __deepcopy__() (airflow.models.param.ParamsDict method) __delitem__() (airflow.models.param.ParamsDict method) __enter__() (airflow.decorators.setup_teardown.ContextWrapper method) __eq__() (airflow.models.param.ParamsDict method) (airflow.models.taskinstance.SimpleTaskInstance method) (airflow.timetables._cron.CronMixin method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) (airflow.triggers.base.TriggerEvent method) __exit__() (airflow.decorators.setup_teardown.ContextWrapper method) __getattr__() (airflow.decorators.TaskDecoratorCollection method) __getitem__() (airflow.models.param.ParamsDict method) __hash__() (airflow.decorators.base.DecoratedMappedOperator method) (airflow.models.taskinstance.TaskInstance method) __init module __iter__() (airflow.models.param.ParamsDict method) __len__() (airflow.models.param.ParamsDict method) __repr__() (airflow.exceptions.TaskDeferred method) (airflow.models.connection.Connection method) (airflow.models.dag.DagModel method) (airflow.models.dag.DagOwnerAttributes method) (airflow.models.dag.DagTag method) (airflow.models.dagbag.DagPriorityParsingRequest method) (airflow.models.dagrun.DagRun method) (airflow.models.dagrun.DagRunNote method) (airflow.models.param.ParamsDict method) (airflow.models.taskinstance.SimpleTaskInstance method) (airflow.models.taskinstance.TaskInstance method) (airflow.models.taskinstance.TaskInstanceNote method) (airflow.models.variable.Variable method) (airflow.models.xcom.BaseXCom method) (airflow.timetables.events.EventsTimetable method) (airflow.triggers.base.BaseTrigger method) (airflow.triggers.base.TriggerEvent method)

__setitem__() (airflow.models.param.ParamsDict method) __slots__ (airflow.models.param.ParamsDict attribute) __str__() (airflow.exceptions.AirflowDagDuplicatedIdException method) (airflow.exceptions.AirflowFileParseException method) (airflow.exceptions.DeserializingResultError method) (airflow.exceptions.FailStopDagInvalidTriggerRule method) (airflow.exceptions.FileSyntaxError method) (airflow.exceptions.TaskAlreadyInTaskGroup method) (airflow.exceptions.UnmappableXComLengthPushed method) (airflow.exceptions.UnmappableXComTypePushed method) (airflow.exceptions.XComForMappingNotPushed method) (airflow.exceptions.XComNotFound method) (airflow.models.dag.InconsistentDataInterval method) (airflow.utils.state.DagRunState method) (airflow.utils.state.IntermediateTIState method) (airflow.utils.state.JobState method) (airflow.utils.state.TaskInstanceState method) (airflow.utils.state.TerminalTIState method) __table_args__ (airflow.models.dag.DagModel attribute) (airflow.models.dag.DagTag attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.dagrun.DagRunNote attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.xcom.BaseXCom attribute) __tablename__ (airflow.models.connection.Connection attribute) (airflow.models.dag.DagModel attribute) (airflow.models.dag.DagOwnerAttributes attribute) (airflow.models.dag.DagTag attribute) (airflow.models.dagbag.DagPriorityParsingRequest attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.dagrun.DagRunNote attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.variable.Variable attribute) (airflow.models.xcom.BaseXCom attribute) __version__ (airflow.models.param.Param attribute) (airflow.models.param.ParamsDict attribute) __wrapped__ (airflow.decorators.base.Task property)

A

active_runs_limit (airflow.timetables.base.Timetable attribute) (airflow.timetables.simple.ContinuousTimetable attribute) add_one() (in module airflow.example_dags.example_dynamic_task_mapping) add_one_task (in module airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators) AddOneOperator (class in airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators) adoptable_states (airflow.utils.state.State attribute) AfterWorkdayTimetable (class in airflow.example_dags.plugins.workday) airflow.config_templates.airflow_local_settings module airflow.decorators module airflow.decorators.base module airflow.decorators.bash module airflow.decorators.branch_external_python module airflow.decorators.branch_python module airflow.decorators.branch_virtualenv module airflow.decorators.condition module airflow.decorators.external_python module airflow.decorators.python module airflow.decorators.python_virtualenv module airflow.decorators.sensor module airflow.decorators.setup_teardown module airflow.decorators.short_circuit module airflow.decorators.task_group module airflow.example_dags module airflow.example_dags.example_asset_alias module airflow.example_dags.example_asset_alias_with_no_taskflow module airflow.example_dags.example_asset_decorator module airflow.example_dags.example_asset_with_watchers module airflow.example_dags.example_assets module airflow.example_dags.example_bash_decorator module airflow.example_dags.example_bash_operator module airflow.example_dags.example_branch_datetime_operator module airflow.example_dags.example_branch_day_of_week_operator module airflow.example_dags.example_branch_labels module airflow.example_dags.example_branch_operator module airflow.example_dags.example_branch_operator_decorator module airflow.example_dags.example_branch_python_dop_operator_3 module airflow.example_dags.example_complex module airflow.example_dags.example_display_name module airflow.example_dags.example_dynamic_task_mapping module airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators module airflow.example_dags.example_external_task_marker_dag module airflow.example_dags.example_inlet_event_extra module airflow.example_dags.example_kubernetes_executor module airflow.example_dags.example_latest_only module airflow.example_dags.example_latest_only_with_trigger module airflow.example_dags.example_local_kubernetes_executor module airflow.example_dags.example_nested_branch_dag module airflow.example_dags.example_outlet_event_extra module airflow.example_dags.example_params_trigger_ui module airflow.example_dags.example_params_ui_tutorial module airflow.example_dags.example_passing_params_via_test_command module airflow.example_dags.example_python_context_decorator module airflow.example_dags.example_python_context_operator module airflow.example_dags.example_python_decorator module airflow.example_dags.example_python_operator module airflow.example_dags.example_sensor_decorator module airflow.example_dags.example_sensors module airflow.example_dags.example_setup_teardown module airflow.example_dags.example_setup_teardown_taskflow module airflow.example_dags.example_short_circuit_decorator module airflow.example_dags.example_short_circuit_operator module airflow.example_dags.example_skip_dag module airflow.example_dags.example_task_group module airflow.example_dags.example_task_group_decorator module airflow.example_dags.example_time_delta_sensor_async module airflow.example_dags.example_trigger_controller_dag module airflow.example_dags.example_trigger_target_dag module airflow.example_dags.example_workday_timetable module airflow.example_dags.example_xcom module airflow.example_dags.example_xcomargs module airflow.example_dags.libs module airflow.example_dags.libs.helper module airflow.example_dags.plugins module airflow.example_dags.plugins.decreasing_priority_weight_strategy module

airflow.example_dags.plugins.event_listener module airflow.example_dags.plugins.listener_plugin module airflow.example_dags.plugins.workday module airflow.example_dags.tutorial module airflow.example_dags.tutorial_dag module airflow.example_dags.tutorial_objectstorage module airflow.example_dags.tutorial_taskflow_api module airflow.example_dags.tutorial_taskflow_api_virtualenv module airflow.example_dags.tutorial_taskflow_templates module airflow.exceptions module airflow.hooks module airflow.hooks.base module airflow.macros module airflow.models.baseoperator module airflow.models.baseoperatorlink module airflow.models.connection module airflow.models.dag module airflow.models.dagbag module airflow.models.dagrun module airflow.models.param module airflow.models.taskinstance module airflow.models.taskinstancekey module airflow.models.variable module airflow.models.xcom module airflow.operators module airflow.operators.branch module airflow.operators.email module airflow.operators.empty module airflow.operators.smooth module airflow.policies module airflow.secrets module airflow.secrets.base_secrets module airflow.secrets.cache module airflow.secrets.environment_variables module airflow.secrets.local_filesystem module airflow.secrets.metastore module airflow.sensors module airflow.sensors.base module airflow.timetables module airflow.timetables._cron module airflow.timetables.assets module airflow.timetables.base module airflow.timetables.events module airflow.timetables.interval module airflow.timetables.simple module airflow.timetables.trigger module airflow.triggers module airflow.triggers.base module airflow.triggers.testing module airflow.utils.state module AIRFLOW__{SECTION}__{KEY}, [1] AIRFLOW_CONFIG AIRFLOW_CONN_{CONN_ID}, [1] AIRFLOW_HOME AIRFLOW_VAR_{KEY} AIRFLOW_VAR_{VARIABLE_NAME} AirflowBadRequest AirflowClusterPolicyError AirflowClusterPolicySkipDag AirflowClusterPolicyViolation AirflowConfigException AirflowDagCycleException AirflowDagDuplicatedIdException AirflowException AirflowFailException AirflowFileParseException AirflowNotFoundException AirflowOptionalProviderFeatureException AirflowProviderDeprecationWarning AirflowRescheduleException AirflowSensorTimeout AirflowSkipException AirflowTaskTerminated AirflowTaskTimeout AirflowTimetableInvalid AirflowWebServerTimeout API (in module airflow.example_dags.tutorial_objectstorage) aq_fields (in module airflow.example_dags.tutorial_objectstorage) are_dependencies_met() (airflow.models.taskinstance.TaskInstance method) are_dependents_done() (airflow.models.taskinstance.TaskInstance method) as_json() (airflow.models.connection.Connection method) asset (in module airflow.example_dags.example_asset_with_watchers) (in module airflow.example_dags.example_inlet_event_extra) (in module airflow.example_dags.example_outlet_event_extra) asset1_producer() (in module airflow.example_dags.example_asset_decorator) asset2_producer() (in module airflow.example_dags.example_asset_decorator) asset_condition (airflow.timetables.base.Timetable attribute) asset_expression (airflow.models.dag.DagModel attribute) asset_with_extra_by_context() (in module airflow.example_dags.example_outlet_event_extra) asset_with_extra_by_yield() (in module airflow.example_dags.example_outlet_event_extra) AssetOrTimeSchedule (class in airflow.timetables.assets) AssetT (in module airflow.models.dag)

B

backfill (airflow.models.dagrun.DagRun attribute) backfill_id (airflow.models.dagrun.DagRun attribute) backfill_max_active_runs (airflow.models.dagrun.DagRun attribute) bag_dag() (airflow.models.dagbag.DagBag method) base (in module airflow.example_dags.tutorial_objectstorage) BaseBranchOperator (class in airflow.operators.branch) BaseHook (class in airflow.hooks.base) BaseOperator (class in airflow.models.baseoperator) BaseOperatorLink (class in airflow.models.baseoperatorlink) BaseSecretsBackend (class in airflow.secrets.base_secrets) BaseSensorOperator (class in airflow.sensors.base) BaseTrigger (class in airflow.triggers.base) BaseXCom (class in airflow.models.xcom)

bash (airflow.decorators.TaskDecoratorCollection attribute) bash_op1 (in module airflow.example_dags.example_xcomargs) bash_push (in module airflow.example_dags.example_xcom) branch (airflow.decorators.TaskDecoratorCollection attribute) branch() (in module airflow.example_dags.example_nested_branch_dag) branch_external_python (airflow.decorators.TaskDecoratorCollection attribute) branch_external_python_task() (in module airflow.decorators.branch_external_python) branch_task() (in module airflow.decorators.branch_python) branch_virtualenv (airflow.decorators.TaskDecoratorCollection attribute) branch_virtualenv_task() (in module airflow.decorators.branch_virtualenv) BranchMixIn (class in airflow.operators.branch) build_path() (airflow.secrets.base_secrets.BaseSecretsBackend static method) bulk_write_to_db() (airflow.models.dag.DAG class method) bundle_name (airflow.models.dag.DagModel attribute)

C

calculate_dagrun_date_fields() (airflow.models.dag.DagModel method) can_be_scheduled (airflow.timetables.base.Timetable attribute) (airflow.timetables.simple.NullTimetable attribute) catchup (airflow.timetables.base.TimeRestriction attribute) chain() (in module airflow.models.baseoperator) chain_linear() (in module airflow.models.baseoperator) changed_tis (airflow.models.dagrun.TISchedulingDecision attribute) check_and_change_state_before_execution() (airflow.models.taskinstance.TaskInstance method) check_for_write_conflict() (airflow.models.variable.Variable static method) child_task1 (in module airflow.example_dags.example_external_task_marker_dag) choose_branch() (airflow.operators.branch.BaseBranchOperator method) CLASS_IDENTIFIER (airflow.models.param.Param attribute) cleanup() (airflow.triggers.base.BaseTrigger method) clear() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.models.xcom.BaseXCom static method) clear_dags() (airflow.models.dag.DAG class method) clear_next_method_args() (airflow.models.taskinstance.TaskInstance method) clear_number (airflow.models.dagrun.DagRun attribute) clear_task_instances() (in module airflow.models.taskinstance) clear_xcom_data() (airflow.models.taskinstance.TaskInstance method) cli() (airflow.models.dag.DAG method) coerce_resources() (in module airflow.models.baseoperator) coerce_timedelta() (in module airflow.models.baseoperator) collect_dags() (airflow.models.dagbag.DagBag method) collect_dags_from_db() (airflow.models.dagbag.DagBag method) color() (airflow.utils.state.State class method) color_fg() (airflow.utils.state.State class method) command_as_list() (airflow.models.taskinstance.TaskInstance method) cond (in module airflow.example_dags.example_branch_python_dop_operator_3) cond1 (in module airflow.example_dags.example_branch_datetime_operator) cond2 (in module airflow.example_dags.example_branch_datetime_operator) cond3 (in module airflow.example_dags.example_branch_datetime_operator) cond_true (in module airflow.example_dags.example_short_circuit_operator)

conf (airflow.models.dagrun.DagRun attribute) CONN_ENV_PREFIX (in module airflow.secrets.environment_variables) conn_id (airflow.models.connection.Connection attribute) CONN_ID_MAX_LEN (in module airflow.models.connection) conn_name_attr (airflow.hooks.base.DiscoverableHook attribute) conn_type (airflow.hooks.base.DiscoverableHook attribute) (airflow.models.connection.Connection attribute) Connection (class in airflow.models.connection) ConnectionNotUnique consume_asset_event() (in module airflow.example_dags.example_asset_alias) (in module airflow.example_dags.example_asset_alias_with_no_taskflow) consume_asset_event_from_asset_alias() (in module airflow.example_dags.example_asset_alias) (in module airflow.example_dags.example_asset_alias_with_no_taskflow) consumes_asset_decorator() (in module airflow.example_dags.example_asset_decorator) content (airflow.models.dagrun.DagRunNote attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) context_wrapper (in module airflow.decorators.setup_teardown) ContextWrapper (class in airflow.decorators.setup_teardown) ContinuousTimetable (class in airflow.timetables.simple) create_dagrun() (airflow.models.dag.DAG method) create_entry_group (in module airflow.example_dags.example_complex) create_file() (in module airflow.example_dags.example_asset_with_watchers) create_test_pipeline() (in module airflow.example_dags.example_skip_dag) created_at (airflow.models.dagrun.DagRunNote attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) CreatedTasks (in module airflow.models.dagrun) creating_job_id (airflow.models.dagrun.DagRun attribute) CronDataIntervalTimetable (class in airflow.timetables.interval) CronMixin (class in airflow.timetables._cron) CronTriggerTimetable (class in airflow.timetables.trigger) cross_downstream() (in module airflow.models.baseoperator) current_state() (airflow.models.taskinstance.TaskInstance method) custom_operator_name (airflow.decorators.sensor.DecoratedSensorOperator attribute) (airflow.models.taskinstance.TaskInstance attribute)

D

DAG (class in airflow.models.dag) dag (in module airflow.models.dag) dag1 (in module airflow.example_dags.example_branch_datetime_operator) dag1_asset (in module airflow.example_dags.example_assets) dag2 (in module airflow.example_dags.example_branch_datetime_operator) dag2_asset (in module airflow.example_dags.example_assets) dag3 (in module airflow.example_dags.example_branch_datetime_operator) dag3_asset (in module airflow.example_dags.example_assets) dag_display_name() (airflow.models.dag.DagModel method) dag_id (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) (airflow.models.dag.DagOwnerAttributes attribute) (airflow.models.dag.DagTag attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.taskinstancekey.TaskInstanceKey attribute) (airflow.models.xcom.BaseXCom attribute) dag_ids (airflow.models.dagbag.DagBag property) dag_model (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) dag_num (airflow.models.dagbag.FileLoadStat attribute) dag_owner_links (airflow.models.dag.DagModel attribute) dag_policy() (in module airflow.policies) dag_run (airflow.models.dagrun.DagRunNote attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.xcom.BaseXCom attribute) dag_run_id (airflow.models.dagrun.DagRunNote attribute) (airflow.models.xcom.BaseXCom attribute) dag_run_note (airflow.models.dagrun.DagRun attribute) dag_states (airflow.utils.state.State attribute) dag_version (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) dag_version_id (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) dag_versions (airflow.models.dag.DagModel attribute) dag_warnings (airflow.models.dagbag.DagBag property) DagBag (class in airflow.models.dagbag) dagbag_report() (airflow.models.dagbag.DagBag method) DagCodeNotFound DagFileExists DagModel (class in airflow.models.dag) DagNotFound DagOwnerAttributes (class in airflow.models.dag) DagParam (class in airflow.models.param) DagPriorityParsingRequest (class in airflow.models.dagbag) DagRun (class in airflow.models.dagrun) DagRunAlreadyExists DagRunInfo (class in airflow.timetables.base) DagRunNote (class in airflow.models.dagrun) DagRunNotFound DagRunState (class in airflow.utils.state) dags (airflow.models.dagbag.FileLoadStat attribute) dags_needing_dagruns() (airflow.models.dag.DagModel class method) DagStateChangeCallback (in module airflow.models.dag) DagTag (class in airflow.models.dag) data_interval (airflow.timetables.base.DagRunInfo attribute) data_interval_end (airflow.models.dagrun.DagRun attribute) data_interval_start (airflow.models.dagrun.DagRun attribute) DataInterval (class in airflow.timetables.base) datetime_diff_for_humans() (in module airflow.macros)

deactivate_deleted_dags() (airflow.models.dag.DagModel class method) deactivate_stale_dags() (airflow.models.dag.DAG static method) deactivate_unknown_dags() (airflow.models.dag.DAG static method) DecoratedMappedOperator (class in airflow.decorators.base) DecoratedOperator (class in airflow.decorators.base) DecoratedSensorOperator (class in airflow.decorators.sensor) decorator() (airflow.models.baseoperator.ExecutorSafeguard class method) DecreasingPriorityStrategy (class in airflow.example_dags.plugins.decreasing_priority_weight_strategy) DecreasingPriorityWeightStrategyPlugin (class in airflow.example_dags.plugins.decreasing_priority_weight_strategy) default_conn_name (airflow.hooks.base.DiscoverableHook attribute) DEFAULT_DAGRUNS_TO_EXAMINE (airflow.models.dagrun.DagRun attribute) DEFAULT_SECRETS_SEARCH_PATH (in module airflow.secrets) default_view (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) DEFAULT_VIEW_PRESETS (in module airflow.models.dag) defer() (airflow.models.baseoperator.BaseOperator method) defer_task() (airflow.models.taskinstance.TaskInstance method) DEFERRED (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) delete() (airflow.models.variable.Variable static method) (airflow.models.xcom.BaseXCom class method) delete_file() (in module airflow.example_dags.example_asset_with_watchers) Delta (in module airflow.timetables.interval) DeltaDataIntervalTimetable (class in airflow.timetables.interval) deprecated_provider_since (airflow.exceptions.AirflowProviderDeprecationWarning attribute) deprecated_since (airflow.exceptions.RemovedInAirflow3Warning attribute) deps (airflow.models.baseoperator.BaseOperator attribute) (airflow.sensors.base.BaseSensorOperator attribute) description (airflow.models.connection.Connection attribute) (airflow.models.dag.DagModel attribute) (airflow.models.variable.Variable attribute) (airflow.timetables.base.Timetable attribute) (airflow.timetables.simple.ContinuousTimetable attribute) (airflow.timetables.simple.NullTimetable attribute) (airflow.timetables.simple.OnceTimetable attribute) deserialize() (airflow.models.param.DagParam class method) (airflow.models.param.Param static method) (airflow.models.param.ParamsDict static method) (airflow.timetables.assets.AssetOrTimeSchedule class method) (airflow.timetables.base.Timetable class method) (airflow.timetables.events.EventsTimetable class method) (airflow.timetables.interval.CronDataIntervalTimetable class method) (airflow.timetables.interval.DeltaDataIntervalTimetable class method) (airflow.timetables.trigger.CronTriggerTimetable class method) deserialize_connection() (airflow.secrets.base_secrets.BaseSecretsBackend method) deserialize_value() (airflow.models.xcom.BaseXCom static method) DeserializingResultError DiscoverableHook (class in airflow.hooks.base) do_branch() (airflow.operators.branch.BranchMixIn method) dry_run() (airflow.models.baseoperator.BaseOperator method) (airflow.models.taskinstance.TaskInstance method) ds_add() (in module airflow.macros) ds_format() (in module airflow.macros) ds_format_locale() (in module airflow.macros) dump() (airflow.models.param.Param method) (airflow.models.param.ParamsDict method) DuplicateTaskIdFound duration (airflow.models.dagbag.FileLoadStat attribute) (airflow.models.taskinstance.TaskInstance attribute) duration_expression_update() (airflow.models.taskinstance.TaskInstance class method)

E

earliest (airflow.timetables.base.TimeRestriction attribute) email_alert() (airflow.models.taskinstance.TaskInstance method) EmailOperator (class in airflow.operators.email) emit_state_change_metric() (airflow.models.taskinstance.TaskInstance method) empty_task_1 (in module airflow.example_dags.example_branch_day_of_week_operator) empty_task_11 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_12 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_13 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_21 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_22 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_23 (in module airflow.example_dags.example_branch_datetime_operator) EmptyOperator (class in airflow.operators.empty) EmptySkipOperator (class in airflow.example_dags.example_skip_dag) end (airflow.timetables.base.DataInterval attribute) end_date (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) ensure_dag() (airflow.models.taskinstance.TaskInstance class method) 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] EnvironmentVariablesBackend (class in airflow.secrets.environment_variables) error() (airflow.models.taskinstance.TaskInstance method) EventsTimetable (class in airflow.timetables.events) exact() (airflow.timetables.base.DagRunInfo class method) (airflow.timetables.base.DataInterval class method)

example_bash_decorator() (in module airflow.example_dags.example_bash_decorator) example_dag (in module airflow.example_dags.example_display_name) (in module airflow.example_dags.example_short_circuit_decorator) example_display_name() (in module airflow.example_dags.example_display_name) example_python_context_decorator() (in module airflow.example_dags.example_python_context_decorator) example_python_decorator() (in module airflow.example_dags.example_python_decorator) example_sensor_decorator() (in module airflow.example_dags.example_sensor_decorator) example_short_circuit_decorator() (in module airflow.example_dags.example_short_circuit_decorator) execute() (airflow.decorators.base.DecoratedOperator method) (airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.AddOneOperator method) (airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.SumItOperator method) (airflow.example_dags.example_skip_dag.EmptySkipOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.branch.BaseBranchOperator method) (airflow.operators.email.EmailOperator method) (airflow.operators.empty.EmptyOperator method) (airflow.operators.smooth.SmoothOperator method) (airflow.sensors.base.BaseSensorOperator method) execute_callback() (airflow.models.dag.DAG class method) executor (airflow.models.taskinstance.TaskInstance attribute) executor_config (airflow.models.taskinstance.TaskInstance attribute) ExecutorSafeguard (class in airflow.models.baseoperator) expand() (airflow.decorators.base.Task method) expand_kwargs() (airflow.decorators.base.Task method) external_executor_id (airflow.models.taskinstance.TaskInstance attribute) external_python (airflow.decorators.TaskDecoratorCollection attribute) external_trigger (airflow.models.dagrun.DagRun attribute) extra (airflow.models.connection.Connection property) extra_dejson (airflow.models.connection.Connection property) EXTRA_KEY (airflow.models.connection.Connection attribute) extract() (in module airflow.example_dags.tutorial_dag)

F

FAILED (airflow.utils.state.DagRunState attribute) (airflow.utils.state.JobState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute) failed_states (airflow.utils.state.State attribute) FailStopDagInvalidTriggerRule failure_callable() (in module airflow.example_dags.example_sensors) FailureTrigger (class in airflow.triggers.testing) Feature releases fetch_callback() (airflow.models.dag.DAG static method) fetch_dagrun() (airflow.models.dag.DAG static method) fetch_handle_failure_context() (airflow.models.taskinstance.TaskInstance class method) fetch_task_instance() (airflow.models.dagrun.DagRun static method) fetch_task_instances() (airflow.models.dagrun.DagRun static method) file (airflow.models.dagbag.FileLoadStat attribute) FILE_PARSERS (in module airflow.secrets.local_filesystem) file_path (in module airflow.example_dags.example_asset_with_watchers)

FileLoadStat (class in airflow.models.dagbag) fileloc (airflow.models.dag.DagModel attribute) (airflow.models.dagbag.DagPriorityParsingRequest attribute) FileSyntaxError (class in airflow.exceptions) filter_for_tis() (airflow.models.taskinstance.TaskInstance static method) find() (airflow.models.dagrun.DagRun class method) find_duplicate() (airflow.models.dagrun.DagRun class method) finished (airflow.utils.state.State attribute) finished_dr_states (airflow.utils.state.State attribute) finished_tis (airflow.models.dagrun.TISchedulingDecision attribute) FLASK_APP FParams (in module airflow.decorators.base) (in module airflow.decorators.task_group) FReturn (in module airflow.decorators.base) (in module airflow.decorators.task_group) from_dict() (airflow.models.taskinstancekey.TaskInstanceKey class method) from_json() (airflow.models.connection.Connection class method) from_ti() (airflow.models.taskinstance.SimpleTaskInstance class method) function (airflow.decorators.base.Task attribute)

G

generate_command() (airflow.models.taskinstance.TaskInstance static method) generate_md5_hash() (in module airflow.models.dagbag) generate_run_id() (airflow.models.dagrun.DagRun static method) (airflow.timetables.assets.AssetOrTimeSchedule method) (airflow.timetables.base.Timetable method) generate_value() (in module airflow.example_dags.example_xcomargs) get() (airflow.models.variable.Variable class method) get_active_runs() (airflow.models.dag.DAG method) get_airflow_context_vars() (in module airflow.policies) get_all() (airflow.models.dag.DagOwnerAttributes class method) get_asset_triggered_next_run_info() (airflow.models.dag.DagModel method) (in module airflow.models.dag) get_concurrency_reached() (airflow.models.dag.DAG method) get_config() (airflow.secrets.base_secrets.BaseSecretsBackend method) get_conn() (airflow.hooks.base.BaseHook method) get_conn_value() (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.secrets.environment_variables.EnvironmentVariablesBackend method) get_connection() (airflow.hooks.base.BaseHook class method) (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.secrets.local_filesystem.LocalFilesystemBackend method) (airflow.secrets.metastore.MetastoreBackend method) get_connection_form_widgets() (airflow.hooks.base.BaseHook class method) (airflow.hooks.base.DiscoverableHook static method) get_connection_from_secrets() (airflow.models.connection.Connection class method) get_connection_parameter_names() (in module airflow.secrets.local_filesystem) get_connection_uri() (airflow.secrets.cache.SecretCache class method) get_current() (airflow.models.dag.DagModel class method) get_dag() (airflow.models.dagbag.DagBag method) (airflow.models.dagrun.DagRun method) get_dagmodel() (airflow.models.dag.DagModel static method) get_dagrun() (airflow.models.dag.DAG method) (airflow.models.taskinstance.TaskInstance method) get_dagruns_between() (airflow.models.dag.DAG method) get_default_view() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) get_direct_relatives() (airflow.models.baseoperator.BaseOperator method) get_email_subject_content() (airflow.models.taskinstance.TaskInstance method) get_extra() (airflow.models.connection.Connection method) get_extra_dejson() (airflow.models.connection.Connection method) get_failed_dep_statuses() (airflow.models.taskinstance.TaskInstance method) get_hook() (airflow.hooks.base.BaseHook class method) (airflow.models.connection.Connection method) get_is_active() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) get_is_paused() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) get_last_dagrun() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (in module airflow.models.dag)

get_latest_logical_date() (airflow.models.dag.DAG method) get_latest_runs() (airflow.models.dagrun.DagRun class method) get_link() (airflow.models.baseoperatorlink.BaseOperatorLink method) get_log_template() (airflow.models.dagrun.DagRun method) get_many() (airflow.models.xcom.BaseXCom static method) get_names() (in module airflow.example_dags.example_params_trigger_ui) get_next_workday() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method) get_num_running_task_instances() (airflow.models.taskinstance.TaskInstance method) get_num_task_instances() (airflow.models.dag.DAG static method) get_one() (airflow.models.xcom.BaseXCom static method) get_param() (airflow.models.param.ParamsDict method) get_password() (airflow.models.connection.Connection method) get_paused_dag_ids() (airflow.models.dag.DagModel static method) get_previous_dagrun() (airflow.models.dagrun.DagRun static method) (airflow.models.taskinstance.TaskInstance method) get_previous_logical_date() (airflow.models.taskinstance.TaskInstance method) get_previous_scheduled_dagrun() (airflow.models.dagrun.DagRun static method) get_previous_start_date() (airflow.models.taskinstance.TaskInstance method) get_previous_ti() (airflow.models.taskinstance.TaskInstance method) get_python_source() (airflow.decorators.base.DecoratedOperator method) get_relevant_upstream_map_indexes() (airflow.models.taskinstance.TaskInstance method) get_rendered_template_fields() (airflow.models.taskinstance.TaskInstance method) get_serialized_fields() (airflow.models.baseoperator.BaseOperator class method) (airflow.models.dag.DAG class method) (airflow.sensors.base.BaseSensorOperator class method) get_state() (airflow.models.dagrun.DagRun method) get_task_assets() (airflow.models.dag.DAG method) get_task_instance() (airflow.models.dagrun.DagRun method) (airflow.models.taskinstance.TaskInstance class method) get_task_instances() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.models.dagrun.DagRun method) get_task_instances_before() (airflow.models.dag.DAG method) get_template_context() (airflow.models.taskinstance.TaskInstance method) get_ui_field_behaviour() (airflow.hooks.base.BaseHook class method) (airflow.hooks.base.DiscoverableHook static method) get_unique_task_id() (in module airflow.decorators.base) get_upstream_assets() (in module structure) get_uri() (airflow.models.connection.Connection method) get_val() (airflow.models.variable.Variable method) get_value() (airflow.models.xcom.BaseXCom static method) get_variable() (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.secrets.cache.SecretCache class method) (airflow.secrets.environment_variables.EnvironmentVariablesBackend method) (airflow.secrets.local_filesystem.LocalFilesystemBackend method) (airflow.secrets.metastore.MetastoreBackend method) get_variable_from_secrets() (airflow.models.variable.Variable static method) get_weight() (airflow.example_dags.plugins.decreasing_priority_weight_strategy.DecreasingPriorityStrategy method)

H

handle_callback() (airflow.models.dag.DAG method) handle_failure() (airflow.models.taskinstance.TaskInstance method) handle_submit() (airflow.triggers.base.TriggerEvent method) has_dag_runs() (airflow.models.dag.DAG method) has_import_errors (airflow.models.dag.DagModel attribute)

has_task_concurrency_limits (airflow.models.dag.DagModel attribute) has_value (airflow.models.param.Param property) holiday_calendar (in module airflow.example_dags.plugins.workday) hook_name (airflow.hooks.base.DiscoverableHook attribute) host (airflow.models.connection.Connection attribute) hostname (airflow.models.taskinstance.TaskInstance attribute)

I

id (airflow.models.connection.Connection attribute) (airflow.models.dagbag.DagPriorityParsingRequest attribute) (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.variable.Variable attribute) InconsistentDataInterval infer_manual_data_interval() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method) (airflow.timetables.assets.AssetOrTimeSchedule method) (airflow.timetables.base.Timetable method) (airflow.timetables.events.EventsTimetable method) (airflow.timetables.interval.CronDataIntervalTimetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) (airflow.timetables.trigger.CronTriggerTimetable method) ingest (in module airflow.example_dags.example_branch_labels) inherits_from_empty_operator (airflow.operators.empty.EmptyOperator attribute) init() (airflow.secrets.cache.SecretCache class method) init_on_load() (airflow.models.taskinstance.TaskInstance method) (airflow.models.xcom.BaseXCom method)

init_run_context() (airflow.models.taskinstance.TaskInstance method) IntermediateTIState (class in airflow.utils.state) interval() (airflow.timetables.base.DagRunInfo class method) invalidate_variable() (airflow.secrets.cache.SecretCache class method) InvalidStatsNameException is_active (airflow.models.dag.DagModel attribute) is_eligible_to_retry() (airflow.models.taskinstance.TaskInstance method) is_encrypted (airflow.models.connection.Connection attribute) (airflow.models.variable.Variable attribute) is_extra_encrypted (airflow.models.connection.Connection attribute) is_paused (airflow.models.dag.DagModel attribute) is_paused_at_creation (airflow.models.dag.DagModel attribute) is_premature (airflow.models.taskinstance.TaskInstance property) is_trigger_log_context (airflow.models.taskinstance.TaskInstance attribute) items() (airflow.models.param.ParamsDict method) iter_dagrun_infos_between() (airflow.models.dag.DAG method)

J

JobState (class in airflow.utils.state)

K

k8s (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor) key (airflow.models.taskinstance.TaskInstance property) (airflow.models.taskinstancekey.TaskInstanceKey property) (airflow.models.variable.Variable attribute) (airflow.models.xcom.BaseXCom attribute)

L

last_expired (airflow.models.dag.DagModel attribute) last_heartbeat_at (airflow.models.taskinstance.TaskInstance attribute) last_loaded (airflow.models.dag.DAG attribute) last_parsed_time (airflow.models.dag.DagModel attribute) last_scheduling_decision (airflow.models.dagrun.DagRun attribute) latest (airflow.timetables.base.TimeRestriction attribute) latest_bundle_version (airflow.models.dag.DagModel attribute) latest_only (in module airflow.example_dags.example_latest_only) (in module airflow.example_dags.example_latest_only_with_trigger) line_no (airflow.exceptions.FileSyntaxError attribute) link (airflow.models.dag.DagOwnerAttributes attribute) listeners (airflow.example_dags.plugins.listener_plugin.MetadataCollectionPlugin attribute) load_connections_dict() (in module airflow.secrets.local_filesystem) load_variables() (in module airflow.secrets.local_filesystem) LocalFilesystemBackend (class in airflow.secrets.local_filesystem) log (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor) (in module airflow.example_dags.example_python_decorator) (in module airflow.example_dags.example_python_operator) (in module airflow.example_dags.example_xcomargs) (in module airflow.example_dags.plugins.workday) (in module airflow.example_dags.tutorial_taskflow_api_virtualenv) (in module airflow.hooks.base) (in module airflow.models.connection) (in module airflow.models.dag) (in module airflow.models.taskinstance) (in module airflow.models.variable) (in module airflow.models.xcom) (in module airflow.secrets.local_filesystem) (in module airflow.triggers.base)

log_template_id (airflow.models.dagrun.DagRun attribute) log_url (airflow.models.taskinstance.TaskInstance property) logger (in module airflow.models.baseoperator) (in module airflow.models.param) logical_date (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.xcom.BaseXCom attribute) (airflow.timetables.base.DagRunInfo property) login (airflow.models.connection.Connection attribute)

M

Major release map_index (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.taskinstancekey.TaskInstanceKey attribute) (airflow.models.xcom.BaseXCom attribute) mark_success_url (airflow.models.taskinstance.TaskInstance property) max_active_runs (airflow.models.dag.DagModel attribute) (airflow.models.dagrun.DagRun attribute) max_active_tasks (airflow.models.dag.DagModel attribute) max_consecutive_failed_dag_runs (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) max_tries (airflow.models.taskinstance.TaskInstance attribute) message (airflow.exceptions.FileSyntaxError attribute) MetadataCollectionPlugin (class in airflow.example_dags.plugins.listener_plugin) MetastoreBackend (class in airflow.secrets.metastore) module __init airflow.config_templates.airflow_local_settings airflow.decorators airflow.decorators.base airflow.decorators.bash airflow.decorators.branch_external_python airflow.decorators.branch_python airflow.decorators.branch_virtualenv airflow.decorators.condition airflow.decorators.external_python airflow.decorators.python airflow.decorators.python_virtualenv airflow.decorators.sensor airflow.decorators.setup_teardown airflow.decorators.short_circuit airflow.decorators.task_group airflow.example_dags airflow.example_dags.example_asset_alias airflow.example_dags.example_asset_alias_with_no_taskflow airflow.example_dags.example_asset_decorator airflow.example_dags.example_asset_with_watchers airflow.example_dags.example_assets airflow.example_dags.example_bash_decorator airflow.example_dags.example_bash_operator airflow.example_dags.example_branch_datetime_operator airflow.example_dags.example_branch_day_of_week_operator airflow.example_dags.example_branch_labels airflow.example_dags.example_branch_operator airflow.example_dags.example_branch_operator_decorator airflow.example_dags.example_branch_python_dop_operator_3 airflow.example_dags.example_complex airflow.example_dags.example_display_name airflow.example_dags.example_dynamic_task_mapping airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators airflow.example_dags.example_external_task_marker_dag airflow.example_dags.example_inlet_event_extra airflow.example_dags.example_kubernetes_executor airflow.example_dags.example_latest_only airflow.example_dags.example_latest_only_with_trigger airflow.example_dags.example_local_kubernetes_executor airflow.example_dags.example_nested_branch_dag airflow.example_dags.example_outlet_event_extra airflow.example_dags.example_params_trigger_ui airflow.example_dags.example_params_ui_tutorial airflow.example_dags.example_passing_params_via_test_command airflow.example_dags.example_python_context_decorator airflow.example_dags.example_python_context_operator airflow.example_dags.example_python_decorator airflow.example_dags.example_python_operator airflow.example_dags.example_sensor_decorator airflow.example_dags.example_sensors airflow.example_dags.example_setup_teardown airflow.example_dags.example_setup_teardown_taskflow airflow.example_dags.example_short_circuit_decorator airflow.example_dags.example_short_circuit_operator airflow.example_dags.example_skip_dag airflow.example_dags.example_task_group airflow.example_dags.example_task_group_decorator airflow.example_dags.example_time_delta_sensor_async airflow.example_dags.example_trigger_controller_dag airflow.example_dags.example_trigger_target_dag airflow.example_dags.example_workday_timetable airflow.example_dags.example_xcom airflow.example_dags.example_xcomargs airflow.example_dags.libs airflow.example_dags.libs.helper airflow.example_dags.plugins airflow.example_dags.plugins.decreasing_priority_weight_strategy airflow.example_dags.plugins.event_listener airflow.example_dags.plugins.listener_plugin airflow.example_dags.plugins.workday airflow.example_dags.tutorial airflow.example_dags.tutorial_dag airflow.example_dags.tutorial_objectstorage airflow.example_dags.tutorial_taskflow_api airflow.example_dags.tutorial_taskflow_api_virtualenv airflow.example_dags.tutorial_taskflow_templates airflow.exceptions airflow.hooks airflow.hooks.base airflow.macros airflow.models.baseoperator airflow.models.baseoperatorlink airflow.models.connection airflow.models.dag airflow.models.dagbag airflow.models.dagrun airflow.models.param airflow.models.taskinstance airflow.models.taskinstancekey airflow.models.variable airflow.models.xcom airflow.operators airflow.operators.branch airflow.operators.email airflow.operators.empty airflow.operators.smooth airflow.policies airflow.secrets airflow.secrets.base_secrets airflow.secrets.cache airflow.secrets.environment_variables airflow.secrets.local_filesystem airflow.secrets.metastore airflow.sensors airflow.sensors.base airflow.timetables airflow.timetables._cron airflow.timetables.assets airflow.timetables.base airflow.timetables.events airflow.timetables.interval airflow.timetables.simple airflow.timetables.trigger airflow.triggers airflow.triggers.base airflow.triggers.testing airflow.utils.state structure tests.system.core tests.system.core.example_external_task_child_deferrable tests.system.core.example_external_task_parent_deferrable

multiple_outputs (airflow.decorators.base.DecoratedMappedOperator attribute) my_first_task() (in module airflow.example_dags.example_setup_teardown_taskflow) my_py_command() (in module airflow.example_dags.example_passing_params_via_test_command)

N

name (airflow.example_dags.plugins.decreasing_priority_weight_strategy.DecreasingPriorityWeightStrategyPlugin attribute) (airflow.example_dags.plugins.listener_plugin.MetadataCollectionPlugin attribute) (airflow.example_dags.plugins.workday.WorkdayTimetablePlugin attribute) (airflow.models.baseoperatorlink.BaseOperatorLink property) (airflow.models.dag.DagTag attribute) next_dagrun (airflow.models.dag.DagModel attribute) next_dagrun_create_after (airflow.models.dag.DagModel attribute) next_dagrun_data_interval (airflow.models.dag.DagModel property) next_dagrun_data_interval_end (airflow.models.dag.DagModel attribute) next_dagrun_data_interval_start (airflow.models.dag.DagModel attribute) next_dagrun_info() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method) (airflow.models.dag.DAG method) (airflow.timetables.assets.AssetOrTimeSchedule method) (airflow.timetables.base.Timetable method) (airflow.timetables.events.EventsTimetable method) (airflow.timetables.simple.ContinuousTimetable method) (airflow.timetables.simple.NullTimetable method) (airflow.timetables.simple.OnceTimetable method) (airflow.timetables.trigger.CronTriggerTimetable method)

next_kwargs (airflow.models.taskinstance.TaskInstance attribute) (airflow.triggers.base.StartTriggerArgs attribute) next_method (airflow.models.taskinstance.TaskInstance attribute) (airflow.triggers.base.StartTriggerArgs attribute) next_retry_datetime() (airflow.models.taskinstance.TaskInstance method) NONE (airflow.utils.state.State attribute) note (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) notify_dagrun_state_changed() (airflow.models.dagrun.DagRun method) NullTimetable (class in airflow.timetables.simple) NUM_DAGS_PER_DAGRUN_QUERY (airflow.models.dag.DagModel attribute)

O

on_dag_run_failed() (in module airflow.example_dags.plugins.event_listener) on_dag_run_running() (in module airflow.example_dags.plugins.event_listener) on_dag_run_success() (in module airflow.example_dags.plugins.event_listener) on_db_load() (airflow.models.connection.Connection method) (airflow.models.variable.Variable method) on_execute_callback (airflow.models.baseoperator.BaseOperator attribute) on_failure_callback (airflow.models.baseoperator.BaseOperator attribute) on_retry_callback (airflow.models.baseoperator.BaseOperator attribute) on_skipped_callback (airflow.models.baseoperator.BaseOperator attribute) on_success_callback (airflow.models.baseoperator.BaseOperator attribute) on_task_instance_failed() (in module airflow.example_dags.plugins.event_listener) on_task_instance_running() (in module airflow.example_dags.plugins.event_listener) on_task_instance_success() (in module airflow.example_dags.plugins.event_listener) OnceTimetable (class in airflow.timetables.simple)

op_kwargs_expand_input (airflow.decorators.base.DecoratedMappedOperator attribute) operator (airflow.models.taskinstance.TaskInstance attribute) operator_extra_links (airflow.models.baseoperator.BaseOperator attribute) operator_name (airflow.models.taskinstance.TaskInstance property) operators (airflow.models.baseoperatorlink.BaseOperatorLink attribute) OperatorSubclass (in module airflow.decorators.base) orientation (airflow.models.dag.DAG attribute) ORIENTATION_PRESETS (in module airflow.models.dag) orm_deserialize_value() (airflow.models.xcom.BaseXCom method) override() (airflow.decorators.base.Task method) (airflow.decorators.base.TaskDecorator method) overwrite_params_with_dag_run_conf() (airflow.models.taskinstance.TaskInstance method) owner (airflow.models.dag.DagOwnerAttributes attribute) owners (airflow.models.dag.DagModel attribute)

P

Param (class in airflow.models.param) ParamsDict (class in airflow.models.param) ParamValidationError parent_task (in module airflow.example_dags.example_external_task_marker_dag) parse_retries() (in module airflow.models.baseoperator) partial (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.dag.DAG attribute) partial() (airflow.decorators.base.Task method) (in module airflow.models.baseoperator) password (airflow.models.connection.Connection property) PAST_DEPENDS_MET (in module airflow.models.taskinstance) Patch releases PATH_TO_PYTHON_BINARY (in module airflow.example_dags.example_branch_operator) (in module airflow.example_dags.example_branch_operator_decorator) (in module airflow.example_dags.example_python_decorator) (in module airflow.example_dags.example_python_operator) periodic (airflow.timetables.base.Timetable attribute) pid (airflow.models.taskinstance.TaskInstance attribute) pod_mutation_hook() (in module airflow.policies) PodMutationHookException PodReconciliationError poke() (airflow.sensors.base.BaseSensorOperator method) poke_mode_only() (in module airflow.sensors.base) PokeReturnValue (class in airflow.sensors.base) pool (airflow.models.taskinstance.TaskInstance attribute) pool_slots (airflow.models.taskinstance.TaskInstance attribute) PoolNotFound

port (airflow.models.connection.Connection attribute) post_execute() (airflow.models.baseoperator.BaseOperator method) pre_execute() (airflow.models.baseoperator.BaseOperator method) prepare_for_execution() (airflow.sensors.base.BaseSensorOperator method) primary (airflow.models.taskinstancekey.TaskInstanceKey property) print_context() (in module airflow.example_dags.example_python_context_operator) (in module airflow.example_dags.example_python_operator) print_env_vars() (in module airflow.example_dags.example_passing_params_via_test_command) print_stuff() (in module airflow.example_dags.libs.helper) print_value() (in module airflow.example_dags.example_xcomargs) priority_weight (airflow.models.taskinstance.TaskInstance attribute) priority_weight_strategies (airflow.example_dags.plugins.decreasing_priority_weight_strategy.DecreasingPriorityWeightStrategyPlugin attribute) process_file() (airflow.models.dagbag.DagBag method) process_params() (in module airflow.models.param) produce_asset_events() (in module airflow.example_dags.example_asset_alias) (in module airflow.example_dags.example_asset_alias_with_no_taskflow) produce_asset_events_through_asset_alias() (in module airflow.example_dags.example_asset_alias) produce_asset_events_through_asset_alias_with_no_taskflow() (in module airflow.example_dags.example_asset_alias_with_no_taskflow) pull_value_from_bash_push() (in module airflow.example_dags.example_xcom) puller() (in module airflow.example_dags.example_xcom) purge() (airflow.models.xcom.BaseXCom static method) push() (in module airflow.example_dags.example_xcom) push_by_returning() (in module airflow.example_dags.example_xcom) python (airflow.decorators.TaskDecoratorCollection attribute) python_callable (airflow.decorators.base.DecoratedMappedOperator attribute) python_task() (in module airflow.decorators.python) PYTHONPATH, [1], [2], [3], [4], [5], [6], [7], [8]

Q

queue (airflow.models.taskinstance.TaskInstance attribute) QUEUED (airflow.utils.state.DagRunState attribute) (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute)

queued_at (airflow.models.dagrun.DagRun attribute) queued_by_job_id (airflow.models.taskinstance.TaskInstance attribute) queued_dttm (airflow.models.taskinstance.TaskInstance attribute)

R

random() (in module airflow.macros) RE_SANITIZE_CONN_ID (in module airflow.models.connection) read_asset_event() (in module airflow.example_dags.example_inlet_event_extra) ready_for_retry() (airflow.models.taskinstance.TaskInstance method) refresh_from_db() (airflow.models.dagrun.DagRun method) (airflow.models.taskinstance.TaskInstance method) refresh_from_task() (airflow.models.taskinstance.TaskInstance method) relative_fileloc (airflow.models.dag.DAG property) (airflow.models.dag.DagModel property) REMOVED (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute) RemovedInAirflow3Warning render_template_fields() (airflow.models.baseoperator.BaseOperator method) render_templates() (airflow.models.taskinstance.TaskInstance method) rendered_map_index (airflow.models.taskinstance.TaskInstance attribute) rendered_task_instance_fields (airflow.models.taskinstance.TaskInstance attribute) repr() (airflow.triggers.base.BaseTrigger static method) reschedule (airflow.sensors.base.BaseSensorOperator property) reset() (airflow.secrets.cache.SecretCache class method) resolve() (airflow.models.param.DagParam method) (airflow.models.param.Param method) resolve_xcom_backend() (in module airflow.models.xcom) RESTARTING (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.JobState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) resume_execution() (airflow.models.baseoperator.BaseOperator method) (airflow.sensors.base.BaseSensorOperator method)

root_setup (in module airflow.example_dags.example_setup_teardown) rotate_fernet_key() (airflow.models.connection.Connection method) (airflow.models.variable.Variable method) run() (airflow.models.baseoperator.BaseOperator method) (airflow.models.taskinstance.TaskInstance method) (airflow.triggers.base.BaseTrigger method) (airflow.triggers.testing.FailureTrigger method) (airflow.triggers.testing.SuccessTrigger method) run_after (airflow.timetables.base.DagRunInfo attribute) run_as_user (airflow.models.taskinstance.TaskInstance attribute) run_id (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.taskinstancekey.TaskInstanceKey attribute) (airflow.models.xcom.BaseXCom attribute) RUN_ID_REGEX (in module airflow.models.dagrun) run_if (airflow.decorators.TaskDecoratorCollection attribute) run_if() (in module airflow.decorators.condition) run_ordering (airflow.timetables.base.Timetable attribute) run_this (in module airflow.example_dags.example_passing_params_via_test_command) (in module airflow.example_dags.example_trigger_target_dag) run_this_first (in module airflow.example_dags.example_branch_operator) (in module airflow.example_dags.example_branch_operator_decorator) run_this_func() (in module airflow.example_dags.example_trigger_target_dag) run_this_last (in module airflow.example_dags.example_bash_operator) run_type (airflow.models.dagrun.DagRun attribute) RUNNING (airflow.utils.state.DagRunState attribute) (airflow.utils.state.JobState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute)

S

safe_dag_id (airflow.models.dag.DAG property) (airflow.models.dag.DagModel property) sanitize_conn_id() (in module airflow.models.connection) save_connection_uri() (airflow.secrets.cache.SecretCache class method) save_to_db() (airflow.models.taskinstance.TaskInstance static method) save_variable() (airflow.secrets.cache.SecretCache class method) schedulable_tis (airflow.models.dagrun.TISchedulingDecision attribute) schedule_asset_alias_references (airflow.models.dag.DagModel attribute) schedule_asset_references (airflow.models.dag.DagModel attribute) schedule_assets (airflow.models.dag.DagModel attribute) schedule_tis() (airflow.models.dagrun.DagRun method) ScheduleArg (in module airflow.models.dag) SCHEDULED (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) ScheduleInterval (in module airflow.models.dag) schema (airflow.models.connection.Connection attribute) SecretCache (class in airflow.secrets.cache) sensor (airflow.decorators.TaskDecoratorCollection attribute) sensor_task() (in module airflow.decorators.sensor) SerializationError serialize() (airflow.exceptions.AirflowException method) (airflow.exceptions.AirflowRescheduleException method) (airflow.exceptions.DagRunAlreadyExists method) (airflow.exceptions.TaskDeferred method) (airflow.exceptions.XComNotFound method) (airflow.models.param.DagParam method) (airflow.models.param.Param method) (airflow.models.param.ParamsDict method) (airflow.timetables.assets.AssetOrTimeSchedule method) (airflow.timetables.base.Timetable method) (airflow.timetables.events.EventsTimetable method) (airflow.timetables.interval.CronDataIntervalTimetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) (airflow.timetables.trigger.CronTriggerTimetable method) (airflow.triggers.base.BaseTrigger method) (airflow.triggers.testing.FailureTrigger method) (airflow.triggers.testing.SuccessTrigger method) serialize_for_task_group() (airflow.models.baseoperator.BaseOperator method) serialize_value() (airflow.models.xcom.BaseXCom static method) set() (airflow.models.variable.Variable static method) (airflow.models.xcom.BaseXCom class method) set_current_context() (in module airflow.models.taskinstance) set_duration() (airflow.models.taskinstance.TaskInstance method) set_extra() (airflow.models.connection.Connection method) set_is_paused() (airflow.models.dag.DagModel method) set_password() (airflow.models.connection.Connection method) set_state() (airflow.models.dagrun.DagRun method) (airflow.models.taskinstance.TaskInstance method) set_task_group_state() (airflow.models.dag.DAG method) set_task_instance_state() (airflow.models.dag.DAG method) set_val() (airflow.models.variable.Variable method) setdefault() (airflow.models.variable.Variable class method) setup (in module airflow.decorators) setup_task() (in module airflow.decorators.setup_teardown) shallow_copy_attrs (airflow.decorators.base.DecoratedOperator attribute) (airflow.decorators.sensor.DecoratedSensorOperator attribute)

short_circuit (airflow.decorators.TaskDecoratorCollection attribute) should_run() (in module airflow.example_dags.example_branch_python_dop_operator_3) show_params() (in module airflow.example_dags.example_params_ui_tutorial) SimpleTaskInstance (class in airflow.models.taskinstance) size() (airflow.models.dagbag.DagBag method) skip_if (airflow.decorators.TaskDecoratorCollection attribute) skip_if() (in module airflow.decorators.condition) SKIPPED (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute) SmoothOperator (class in airflow.operators.smooth) SOME_EXTERNAL_PYTHON (in module airflow.example_dags.example_python_context_decorator) (in module airflow.example_dags.example_python_context_operator) start (airflow.timetables.base.DataInterval attribute) (in module airflow.example_dags.example_task_group) (in module tests.system.core.example_external_task_parent_deferrable) start_date (airflow.models.dagrun.DagRun attribute) (airflow.models.taskinstance.TaskInstance attribute) (in module airflow.example_dags.example_external_task_marker_dag) start_from_trigger (airflow.models.baseoperator.BaseOperator attribute) start_task (in module airflow.example_dags.example_task_group_decorator) start_task_executor_config (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor) start_trigger_args (airflow.models.baseoperator.BaseOperator attribute) StartTriggerArgs (class in airflow.triggers.base) state (airflow.models.dagrun.DagRun property) (airflow.models.taskinstance.TaskInstance attribute) State (class in airflow.utils.state) state_color (airflow.utils.state.State attribute) stats_tags (airflow.models.dagrun.DagRun property) (airflow.models.taskinstance.TaskInstance property) status_code (airflow.exceptions.AirflowBadRequest attribute) (airflow.exceptions.AirflowException attribute) (airflow.exceptions.AirflowNotFoundException attribute) structure module SUCCESS (airflow.utils.state.DagRunState attribute) (airflow.utils.state.JobState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute) success_callable() (in module airflow.example_dags.example_sensors) success_states (airflow.utils.state.State attribute) SuccessTrigger (class in airflow.triggers.testing) SumItOperator (class in airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators) summary (airflow.timetables._cron.CronMixin property) (airflow.timetables.assets.AssetOrTimeSchedule property) (airflow.timetables.base.Timetable property) (airflow.timetables.events.EventsTimetable property) (airflow.timetables.interval.DeltaDataIntervalTimetable property) (airflow.timetables.simple.ContinuousTimetable property) (airflow.timetables.simple.NullTimetable property) (airflow.timetables.simple.OnceTimetable property) sync_to_db() (airflow.models.dag.DAG method) (airflow.models.dagbag.DagBag method)

T

T (in module airflow.models.baseoperator) t0 (in module airflow.example_dags.example_sensors) t1 (in module airflow.example_dags.tutorial) TAG_MAX_LEN (in module airflow.models.dag) tags (airflow.models.dag.DagModel attribute) task (airflow.models.taskinstance.TaskInstance attribute) Task (class in airflow.decorators.base) task (in module airflow.decorators) task_1() (in module airflow.example_dags.example_task_group_decorator) task_2() (in module airflow.example_dags.example_task_group_decorator) task_3() (in module airflow.example_dags.example_task_group_decorator) task_decorator_factory() (in module airflow.decorators.base) task_display_name() (airflow.models.taskinstance.TaskInstance method) task_end() (in module airflow.example_dags.example_task_group_decorator) task_group() (in module airflow.decorators.task_group) task_group_function() (in module airflow.example_dags.example_task_group_decorator) task_group_sig (in module airflow.decorators.task_group) task_id (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.taskinstancekey.TaskInstanceKey attribute) (airflow.models.xcom.BaseXCom attribute) task_instance (airflow.models.taskinstance.TaskInstanceNote attribute) task_instance_mutation_hook() (in module airflow.policies) task_instance_note (airflow.models.taskinstance.TaskInstance attribute) task_instance_scheduling_decisions() (airflow.models.dagrun.DagRun method) task_instance_state (airflow.triggers.base.TaskFailedEvent attribute) (airflow.triggers.base.TaskSkippedEvent attribute) (airflow.triggers.base.TaskSuccessEvent attribute) task_instances (airflow.models.dagrun.DagRun attribute) task_num (airflow.models.dagbag.FileLoadStat attribute) task_outlet_asset_references (airflow.models.dag.DagModel attribute) task_policy() (in module airflow.policies) task_start() (in module airflow.example_dags.example_task_group_decorator) task_states (airflow.utils.state.State attribute) TaskAlreadyInTaskGroup TaskDecorator (class in airflow.decorators.base) TaskDecoratorCollection (class in airflow.decorators) TaskDeferralError TaskDeferralTimeout TaskDeferred TaskFailedEvent (class in airflow.triggers.base) TaskInstance (class in airflow.models.taskinstance) TaskInstanceKey (class in airflow.models.taskinstancekey) TaskInstanceNote (class in airflow.models.taskinstance) TaskInstanceNotFound TaskInstanceState (class in airflow.utils.state) TaskInstanceStateType (in module airflow.models.taskinstance) TaskNotFound TaskPostExecuteHook (in module airflow.models.baseoperator) TaskPreExecuteHook (in module airflow.models.baseoperator) TaskSkippedEvent (class in airflow.triggers.base) TaskSuccessEvent (class in airflow.triggers.base) teardown (in module airflow.decorators)

teardown_task() (in module airflow.decorators.setup_teardown) template_ext (airflow.operators.email.EmailOperator attribute) template_fields (airflow.decorators.base.DecoratedOperator attribute) (airflow.decorators.sensor.DecoratedSensorOperator attribute) (airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.SumItOperator attribute) (airflow.operators.email.EmailOperator attribute) template_fields_renderers (airflow.decorators.base.DecoratedOperator attribute) (airflow.decorators.sensor.DecoratedSensorOperator attribute) (airflow.operators.email.EmailOperator attribute) TerminalTIState (class in airflow.utils.state) test() (airflow.models.dag.DAG method) test_connection() (airflow.models.connection.Connection method) test_mode (airflow.models.baseoperator.ExecutorSafeguard attribute) (airflow.models.taskinstance.TaskInstance attribute) test_run (in module tests.system.core.example_external_task_child_deferrable) (in module tests.system.core.example_external_task_parent_deferrable) tests.system.core module tests.system.core.example_external_task_child_deferrable module tests.system.core.example_external_task_parent_deferrable module this_will_skip (in module airflow.example_dags.example_bash_operator) timeout (airflow.triggers.base.StartTriggerArgs attribute) TimeRestriction (class in airflow.timetables.base) timestamp (airflow.models.xcom.BaseXCom attribute) Timetable (class in airflow.timetables.base) timetable_description (airflow.models.dag.DagModel attribute) timetable_summary (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) timetables (airflow.example_dags.plugins.workday.WorkdayTimetablePlugin attribute) timezone (airflow.models.dag.DagModel property) tis (airflow.models.dagrun.TISchedulingDecision attribute) TISchedulingDecision (class in airflow.models.dagrun) TR (in module airflow.models.taskinstance) trigger (airflow.models.taskinstance.TaskInstance attribute) (in module airflow.example_dags.example_asset_with_watchers) (in module airflow.example_dags.example_trigger_controller_dag) trigger_cls (airflow.triggers.base.StartTriggerArgs attribute) trigger_id (airflow.models.taskinstance.TaskInstance attribute) trigger_kwargs (airflow.triggers.base.StartTriggerArgs attribute) trigger_timeout (airflow.models.taskinstance.TaskInstance attribute) triggered_by (airflow.models.dagrun.DagRun attribute) triggerer_job (airflow.models.taskinstance.TaskInstance attribute) TriggerEvent (class in airflow.triggers.base) try_number (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstancekey.TaskInstanceKey attribute) tutorial_dag (in module airflow.example_dags.tutorial_taskflow_api_virtualenv) tutorial_etl_dag (in module airflow.example_dags.example_sensor_decorator) tutorial_objectstorage() (in module airflow.example_dags.tutorial_objectstorage) tutorial_taskflow_api() (in module airflow.example_dags.tutorial_taskflow_api) tutorial_taskflow_api_virtualenv() (in module airflow.example_dags.tutorial_taskflow_api_virtualenv) tutorial_taskflow_templates() (in module airflow.example_dags.tutorial_taskflow_templates)

U

ui_color (airflow.example_dags.example_skip_dag.EmptySkipOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.empty.EmptyOperator attribute) (airflow.operators.smooth.SmoothOperator attribute) (airflow.sensors.base.BaseSensorOperator attribute) unfinished (airflow.utils.state.State attribute) unfinished_dr_states (airflow.utils.state.State attribute) unfinished_tis (airflow.models.dagrun.TISchedulingDecision attribute) unixname (airflow.models.taskinstance.TaskInstance attribute) UnknownExecutorException UnmappableOperator UnmappableXComLengthPushed UnmappableXComTypePushed UP_FOR_RESCHEDULE (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute)

UP_FOR_RETRY (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) update() (airflow.models.param.ParamsDict method) (airflow.models.variable.Variable static method) update_heartbeat() (airflow.models.taskinstance.TaskInstance method) update_state() (airflow.models.dagrun.DagRun method) updated_at (airflow.models.dagrun.DagRun attribute) (airflow.models.dagrun.DagRunNote attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) UPSTREAM_FAILED (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) user_id (airflow.models.dagrun.DagRunNote attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) uuid7() (in module airflow.models.taskinstance)

V

val (airflow.models.variable.Variable property) valid_modes (airflow.sensors.base.BaseSensorOperator attribute) validate() (airflow.models.dag.DAG method) (airflow.models.param.ParamsDict method) (airflow.timetables._cron.CronMixin method) (airflow.timetables.assets.AssetOrTimeSchedule method) (airflow.timetables.base.Timetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) validate_executor_field() (airflow.models.dag.DAG method)

validate_run_id() (airflow.models.dagrun.DagRun method) value (airflow.models.xcom.BaseXCom attribute) value_1 (in module airflow.example_dags.example_xcom) value_2 (in module airflow.example_dags.example_xcom) values() (airflow.models.param.ParamsDict method) VAR_ENV_PREFIX (in module airflow.secrets.environment_variables) Variable (class in airflow.models.variable) verify_integrity() (airflow.models.dagrun.DagRun method) virtualenv (airflow.decorators.TaskDecoratorCollection attribute)

W

wait (in module airflow.example_dags.example_time_delta_sensor_async) warning_num (airflow.models.dagbag.FileLoadStat attribute) with_try_number() (airflow.models.taskinstancekey.TaskInstanceKey method)

WorkdayTimetablePlugin (class in airflow.example_dags.plugins.workday) worker_container_repository (in module airflow.example_dags.example_local_kubernetes_executor) worker_container_tag (in module airflow.example_dags.example_local_kubernetes_executor)

X

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

xcom_push() (airflow.models.baseoperator.BaseOperator static method) (airflow.models.taskinstance.TaskInstance method) XComForMappingNotPushed XComNotFound

Y

yt_link (airflow.operators.smooth.SmoothOperator attribute)

PreviousNext

Was this entry helpful?