• Home
• Index

Index

_

__attrs_post_init__() (airflow.decorators.base.DecoratedMappedOperator method) (airflow.sensors.external_task.ExternalTaskSensorLink 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.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.models.param.ParamsDict method) __delitem__() (airflow.models.param.ParamsDict method) __enter__() (airflow.models.dag.DAG method) __eq__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.models.param.ParamsDict method) (airflow.models.taskinstance.SimpleTaskInstance method) (airflow.models.xcom.LazyXComAccess method) (airflow.timetables._cron.CronMixin method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) (airflow.triggers.base.TriggerEvent method) __exit__() (airflow.models.dag.DAG method) __getattr__() (airflow.decorators.TaskDecoratorCollection method) __getitem__() (airflow.models.param.ParamsDict method) (airflow.models.xcom.LazyXComAccess method) __getstate__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.xcom.LazyXComAccess method) __gt__() (airflow.models.baseoperator.BaseOperator method) __hash__() (airflow.decorators.base.DecoratedMappedOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) __iter__() (airflow.models.param.ParamsDict method) (airflow.models.xcom.LazyXComAccess method) __len__() (airflow.models.param.ParamsDict method) (airflow.models.xcom.LazyXComAccess method) __lt__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) __ne__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) __or__() (airflow.models.baseoperator.BaseOperator method) __repr__() (airflow.exceptions.TaskDeferred method) (airflow.models.baseoperator.BaseOperator method) (airflow.models.connection.Connection method) (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (airflow.models.dag.DagOwnerAttributes method) (airflow.models.dag.DagTag method) (airflow.models.param.ParamsDict method) (airflow.models.taskinstance.TaskInstance method) (airflow.models.taskinstance.TaskInstanceNote method) (airflow.models.variable.Variable method) (airflow.models.xcom.BaseXCom method) (airflow.models.xcom.LazyXComAccess method) (airflow.timetables.events.EventsTimetable method) (airflow.triggers.base.BaseTrigger method) (airflow.triggers.base.TriggerEvent method)

__setattr__() (airflow.models.baseoperator.BaseOperator method) __setitem__() (airflow.models.param.ParamsDict method) __setstate__() (airflow.models.baseoperator.BaseOperator method) (airflow.models.xcom.LazyXComAccess method) __slots__ (airflow.models.param.ParamsDict attribute) __str__() (airflow.exceptions.AirflowDagDuplicatedIdException method) (airflow.exceptions.AirflowFileParseException method) (airflow.exceptions.FileSyntaxError method) (airflow.exceptions.TaskAlreadyInTaskGroup method) (airflow.exceptions.UnmappableXComLengthPushed method) (airflow.exceptions.UnmappableXComTypePushed method) (airflow.exceptions.XComForMappingNotPushed method) (airflow.exceptions.XComNotFound method) (airflow.models.dag.InconsistentDataInterval method) (airflow.models.xcom.LazyXComAccess method) __table_args__ (airflow.models.dag.DagModel 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.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

access_control (airflow.models.dag.DAG property) active_runs_limit (airflow.timetables.base.Timetable attribute) (airflow.timetables.simple.ContinuousTimetable attribute) add_inlets() (airflow.models.baseoperator.BaseOperator method) add_one() (in module airflow.example_dags.example_dynamic_task_mapping) add_outlets() (airflow.models.baseoperator.BaseOperator method) add_task() (airflow.models.dag.DAG method) add_tasks() (airflow.models.dag.DAG method) AfterWorkdayTimetable (class in airflow.example_dags.plugins.workday) airflow.decorators module airflow.decorators.base module airflow.decorators.branch_python 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_bash_operator module airflow.example_dags.example_branch_datetime_operator module airflow.example_dags.example_branch_day_of_week_operator module airflow.example_dags.example_branch_labels module airflow.example_dags.example_branch_operator module airflow.example_dags.example_branch_operator_decorator module airflow.example_dags.example_branch_python_dop_operator_3 module airflow.example_dags.example_complex module airflow.example_dags.example_datasets module airflow.example_dags.example_dynamic_task_mapping module airflow.example_dags.example_external_task_marker_dag module airflow.example_dags.example_kubernetes_executor module airflow.example_dags.example_latest_only module airflow.example_dags.example_latest_only_with_trigger module airflow.example_dags.example_local_kubernetes_executor module airflow.example_dags.example_nested_branch_dag module airflow.example_dags.example_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_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_subdag_operator module airflow.example_dags.example_task_group module airflow.example_dags.example_task_group_decorator module airflow.example_dags.example_time_delta_sensor_async module airflow.example_dags.example_trigger_controller_dag module airflow.example_dags.example_trigger_target_dag module airflow.example_dags.example_xcom module airflow.example_dags.example_xcomargs module airflow.example_dags.libs module airflow.example_dags.libs.helper module airflow.example_dags.plugins module airflow.example_dags.plugins.event_listener module airflow.example_dags.plugins.listener_plugin module airflow.example_dags.plugins.workday module airflow.example_dags.subdags module airflow.example_dags.subdags.subdag module airflow.example_dags.tutorial module airflow.example_dags.tutorial_dag module airflow.example_dags.tutorial_taskflow_api module airflow.example_dags.tutorial_taskflow_api_virtualenv module airflow.exceptions module airflow.hooks module airflow.hooks.base module airflow.hooks.dbapi module airflow.hooks.filesystem module airflow.hooks.subprocess module

airflow.macros module airflow.models.baseoperator module airflow.models.connection module airflow.models.dag module airflow.models.dagbag module airflow.models.param module airflow.models.taskinstance module airflow.models.variable module airflow.models.xcom module airflow.operators module airflow.operators.bash module airflow.operators.branch module airflow.operators.datetime module airflow.operators.email module airflow.operators.empty module airflow.operators.generic_transfer module airflow.operators.latest_only module airflow.operators.python module airflow.operators.smooth module airflow.operators.subdag module airflow.operators.trigger_dagrun module airflow.operators.weekday module airflow.policies module airflow.secrets module airflow.secrets.base_secrets module airflow.secrets.environment_variables module airflow.secrets.local_filesystem module airflow.secrets.metastore module airflow.sensors module airflow.sensors.base module airflow.sensors.bash module airflow.sensors.date_time module airflow.sensors.external_task module airflow.sensors.filesystem module airflow.sensors.python module airflow.sensors.time_delta module airflow.sensors.time_sensor module airflow.sensors.weekday module airflow.timetables module airflow.timetables._cron module airflow.timetables.base module airflow.timetables.events module airflow.timetables.interval module airflow.timetables.simple module airflow.timetables.trigger module airflow.triggers module airflow.triggers.base module airflow.triggers.external_task module airflow.triggers.file module airflow.triggers.temporal module airflow.triggers.testing module AIRFLOW__{SECTION}__{KEY}, [1] AIRFLOW_CONFIG AIRFLOW_CONN_{CONN_ID}, [1] AIRFLOW_HOME AIRFLOW_VAR_{KEY} AIRFLOW_VAR_{VARIABLE_NAME} AirflowBadRequest AirflowClusterPolicyError AirflowClusterPolicyViolation AirflowConfigException AirflowDagCycleException AirflowDagDuplicatedIdException AirflowDagInconsistent AirflowException AirflowFailException AirflowFileParseException AirflowNotFoundException AirflowOptionalProviderFeatureException AirflowProviderDeprecationWarning AirflowRescheduleException AirflowSensorTimeout AirflowSkipException AirflowTaskTimeout AirflowTimetableInvalid AirflowWebServerTimeout ALL_LEAVES (airflow.operators.subdag.SkippedStatePropagationOptions attribute) allow_future_exec_dates (airflow.models.dag.DAG property) ANY_LEAF (airflow.operators.subdag.SkippedStatePropagationOptions attribute) are_dependencies_met() (airflow.models.taskinstance.TaskInstance method) are_dependents_done() (airflow.models.taskinstance.TaskInstance method) as_dict() (airflow.models.taskinstance.SimpleTaskInstance method) as_setup() (airflow.models.baseoperator.BaseOperator class method) as_teardown() (airflow.models.baseoperator.BaseOperator class method) autoregistered_dags (airflow.models.dag.DagContext attribute)

B

BackfillUnfinished bag_dag() (airflow.models.dagbag.DagBag method) BASE_DIR (in module airflow.example_dags.example_python_operator) BaseBranchOperator (class in airflow.operators.branch) BaseHook (class in airflow.hooks.base) BaseOperator (class in airflow.models.baseoperator) BaseOperatorClassList (in module airflow.models.baseoperator) BaseOperatorLink (class in airflow.models.baseoperator) BaseOperatorMeta (class in airflow.models.baseoperator) BaseSecretsBackend (class in airflow.secrets.base_secrets) BaseSensorOperator (class in airflow.sensors.base) BaseTrigger (class in airflow.triggers.base) BaseXCom (class in airflow.models.xcom) bash_op1 (in module airflow.example_dags.example_xcomargs)

bash_push (in module airflow.example_dags.example_xcom) BashOperator (class in airflow.operators.bash) BashSensor (class in airflow.sensors.bash) BLUE (airflow.operators.python.PythonOperator attribute) branch (airflow.decorators.TaskDecoratorCollection attribute) branch() (in module airflow.example_dags.example_nested_branch_dag) branch_task() (in module airflow.decorators.branch_python) BranchDateTimeOperator (class in airflow.operators.datetime) BranchDayOfWeekOperator (class in airflow.operators.weekday) BranchPythonOperator (class in airflow.operators.python) build_from_xcom_query() (airflow.models.xcom.LazyXComAccess class method) build_path() (airflow.secrets.base_secrets.BaseSecretsBackend static method) bulk_sync_to_db() (airflow.models.dag.DAG class method) bulk_write_to_db() (airflow.models.dag.DAG class method)

C

calculate_dagrun_date_fields() (airflow.models.dag.DagModel method) can_run (airflow.timetables.base.Timetable attribute) catchup (airflow.timetables.base.TimeRestriction attribute) chain() (in module airflow.models.baseoperator) Chainable (in module airflow.models.baseoperator) check_and_change_state_before_execution() (airflow.models.taskinstance.TaskInstance method) check_for_write_conflict() (airflow.models.variable.Variable static method) child_task1 (in module airflow.example_dags.example_external_task_marker_dag) choose_branch() (airflow.operators.branch.BaseBranchOperator method) (airflow.operators.datetime.BranchDateTimeOperator method) (airflow.operators.latest_only.LatestOnlyOperator method) (airflow.operators.weekday.BranchDayOfWeekOperator method) CLASS_IDENTIFIER (airflow.models.param.Param attribute) cleanup() (airflow.triggers.base.BaseTrigger method) clear() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) clear_dags() (airflow.models.dag.DAG class method) clear_db_references() (airflow.models.taskinstance.TaskInstance method) clear_next_method_args() (airflow.models.taskinstance.TaskInstance method) 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) command_as_list() (airflow.models.taskinstance.TaskInstance method) concurrency (airflow.models.dag.DAG property)

concurrency_reached (airflow.models.dag.DAG property) cond (in module airflow.example_dags.example_branch_python_dop_operator_3) cond1 (in module airflow.example_dags.example_branch_datetime_operator) cond2 (in module airflow.example_dags.example_branch_datetime_operator) cond3 (in module airflow.example_dags.example_branch_datetime_operator) cond_true (in module airflow.example_dags.example_short_circuit_operator) CONN_ENV_PREFIX (in module airflow.secrets.environment_variables) conn_id (airflow.models.connection.Connection attribute) conn_name_attr (airflow.hooks.base.DiscoverableHook attribute) conn_type (airflow.hooks.base.DiscoverableHook attribute) (airflow.models.connection.Connection attribute) Connection (class in airflow.models.connection) ConnectionNotUnique content (airflow.models.taskinstance.TaskInstanceNote attribute) ContinuousTimetable (class in airflow.timetables.simple) count_dags() (airflow.triggers.external_task.DagStateTrigger method) count_tasks() (airflow.triggers.external_task.TaskStateTrigger method) create_dagrun() (airflow.models.dag.DAG method) create_entry_group (in module airflow.example_dags.example_complex) create_test_pipeline() (in module airflow.example_dags.example_skip_dag) create_timetable() (in module airflow.models.dag) created_at (airflow.models.taskinstance.TaskInstanceNote attribute) CronDataIntervalTimetable (class in airflow.timetables.interval) CronMixin (class in airflow.timetables._cron) CronTriggerTimetable (class in airflow.timetables.trigger) cross_downstream() (in module airflow.models.baseoperator) current_autoregister_module_name (airflow.models.dag.DagContext attribute) current_state() (airflow.models.taskinstance.TaskInstance method) custom_operator_name (airflow.decorators.sensor.DecoratedSensorOperator attribute)

D

dag (airflow.models.baseoperator.BaseOperator property) DAG (class in airflow.models.dag) dag() (in module airflow.models.dag) dag1 (in module airflow.example_dags.example_branch_datetime_operator) dag1_dataset (in module airflow.example_dags.example_datasets) dag2 (in module airflow.example_dags.example_branch_datetime_operator) dag2_dataset (in module airflow.example_dags.example_datasets) dag3 (in module airflow.example_dags.example_branch_datetime_operator) dag_id (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) (airflow.models.dag.DagOwnerAttributes attribute) (airflow.models.dag.DagTag attribute) (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.xcom.BaseXCom attribute) dag_ids (airflow.models.dagbag.DagBag property) dag_model (airflow.models.taskinstance.TaskInstance attribute) DAG_NAME (in module airflow.example_dags.example_subdag_operator) dag_num (airflow.models.dagbag.FileLoadStat attribute) dag_owner_links (airflow.models.dag.DagModel attribute) dag_policy() (in module airflow.policies) dag_run (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.xcom.BaseXCom attribute) dag_run_id (airflow.models.xcom.BaseXCom attribute) DagBag (class in airflow.models.dagbag) dagbag_report() (airflow.models.dagbag.DagBag method) DagCodeNotFound DagConcurrencyLimitReached DagContext (class in airflow.models.dag) DagFileExists DagModel (class in airflow.models.dag) DagNotFound DagOwnerAttributes (class in airflow.models.dag) DagParam (class in airflow.models.param) DagRunAlreadyExists DagRunInfo (class in airflow.timetables.base) DagRunNotFound dags (airflow.models.dagbag.FileLoadStat attribute) dags_needing_dagruns() (airflow.models.dag.DagModel class method) DagStateChangeCallback (in module airflow.models.dag) DagStateTrigger (class in airflow.triggers.external_task) DagTag (class in airflow.models.dag) data_interval (airflow.timetables.base.DagRunInfo attribute) data_interval_for_events() (airflow.timetables.simple.DatasetTriggeredTimetable method) DataInterval (class in airflow.timetables.base) DatasetTriggeredTimetable (class in airflow.timetables.simple) date_range() (airflow.models.dag.DAG method) datetime_diff_for_humans() (in module airflow.macros) DateTimeSensor (class in airflow.sensors.date_time) DateTimeSensorAsync (class in airflow.sensors.date_time) DateTimeTrigger (class in airflow.triggers.temporal)

DayOfWeekSensor (class in airflow.sensors.weekday) deactivate_deleted_dags() (airflow.models.dag.DagModel class method) deactivate_stale_dags() (airflow.models.dag.DAG static method) deactivate_unknown_dags() (airflow.models.dag.DAG static method) debug_info() (airflow.models.connection.Connection method) DecoratedMappedOperator (class in airflow.decorators.base) DecoratedOperator (class in airflow.decorators.base) DecoratedSensorOperator (class in airflow.decorators.sensor) default_conn_name (airflow.hooks.base.DiscoverableHook attribute) DEFAULT_SCHEDULE_INTERVAL (in module airflow.models.dag) DEFAULT_SECRETS_SEARCH_PATH (in module airflow.secrets) default_view (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) DEFAULT_VIEW_PRESETS (in module airflow.models.dag) defer() (airflow.models.baseoperator.BaseOperator method) DEFERRED (airflow.models.taskinstance.TaskReturnCode attribute) delete() (airflow.models.variable.Variable static method) (airflow.models.xcom.BaseXCom class method) 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.DAG property) (airflow.models.dag.DagModel attribute) (airflow.models.variable.Variable attribute) (airflow.timetables.base.Timetable attribute) (airflow.timetables.simple.ContinuousTimetable attribute) (airflow.timetables.simple.DatasetTriggeredTimetable attribute) (airflow.timetables.simple.NullTimetable attribute) (airflow.timetables.simple.OnceTimetable attribute) deserialize() (airflow.models.param.Param static method) (airflow.models.param.ParamsDict static 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) determine_kwargs() (airflow.operators.python.PythonOperator method) DiscoverableHook (class in airflow.hooks.base) dry_run() (airflow.models.baseoperator.BaseOperator method) (airflow.models.taskinstance.TaskInstance method) ds_add() (in module airflow.macros) ds_format() (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)

E

earliest (airflow.timetables.base.TimeRestriction attribute) email_alert() (airflow.models.taskinstance.TaskInstance method) EmailOperator (class in airflow.operators.email) empty_task_1 (in module airflow.example_dags.example_branch_day_of_week_operator) empty_task_11 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_12 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_13 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_21 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_22 (in module airflow.example_dags.example_branch_datetime_operator) empty_task_23 (in module airflow.example_dags.example_branch_datetime_operator) EmptyOperator (class in airflow.operators.empty) EmptySkipOperator (class in airflow.example_dags.example_skip_dag) end (airflow.timetables.base.DataInterval attribute) end_date (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.taskinstance.TaskInstance attribute) environment variable AIRFLOW__{SECTION}__{KEY}, [1], [2] AIRFLOW__{SECTION}__{KEY}_CMD AIRFLOW__{SECTION}__{KEY}_SECRET AIRFLOW_CONFIG, [1] AIRFLOW_CONN_{CONN_ID}, [1], [2] AIRFLOW_HOME, [1] AIRFLOW_VAR_{KEY}, [1] AIRFLOW_VAR_{VARIABLE_NAME} FLASK_APP PYTHONPATH, [1], [2], [3], [4], [5], [6], [7], [8], [9] EnvironmentVariablesBackend (class in airflow.secrets.environment_variables) error() (airflow.models.taskinstance.TaskInstance method) EventsTimetable (class in airflow.timetables.events) exact() (airflow.timetables.base.DagRunInfo class method) (airflow.timetables.base.DataInterval class method) example_dag (in module airflow.example_dags.example_short_circuit_decorator) example_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_skip_dag.EmptySkipOperator method) (airflow.models.baseoperator.BaseOperator method) (airflow.operators.bash.BashOperator method) (airflow.operators.branch.BaseBranchOperator method) (airflow.operators.email.EmailOperator method) (airflow.operators.empty.EmptyOperator method) (airflow.operators.generic_transfer.GenericTransfer method) (airflow.operators.python.BranchPythonOperator method) (airflow.operators.python.PythonOperator method) (airflow.operators.python.ShortCircuitOperator method) (airflow.operators.smooth.SmoothOperator method) (airflow.operators.trigger_dagrun.TriggerDagRunOperator method) (airflow.sensors.base.BaseSensorOperator method) (airflow.sensors.date_time.DateTimeSensorAsync method) (airflow.sensors.time_delta.TimeDeltaSensorAsync method) (airflow.sensors.time_sensor.TimeSensorAsync method)

execute_callable() (airflow.operators.python.ExternalPythonOperator method) (airflow.operators.python.PythonOperator method) (airflow.operators.python.PythonVirtualenvOperator method) execute_complete() (airflow.operators.trigger_dagrun.TriggerDagRunOperator method) (airflow.sensors.date_time.DateTimeSensorAsync method) (airflow.sensors.time_delta.TimeDeltaSensorAsync method) (airflow.sensors.time_sensor.TimeSensorAsync method) execution_date (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.xcom.BaseXCom attribute) executor_config (airflow.models.taskinstance.TaskInstance attribute) expand() (airflow.decorators.base.Task method) expand_kwargs() (airflow.decorators.base.Task method) ExpandableFactory (class in airflow.decorators.base) external_executor_id (airflow.models.taskinstance.TaskInstance attribute) external_python (airflow.decorators.TaskDecoratorCollection attribute) external_python_task() (in module airflow.decorators.external_python) ExternalDagLink (class in airflow.sensors.external_task) ExternalPythonOperator (class in airflow.operators.python) ExternalTaskMarker (class in airflow.sensors.external_task) ExternalTaskSensor (class in airflow.sensors.external_task) ExternalTaskSensorLink (class in airflow.sensors.external_task) extra (airflow.models.connection.Connection property) extra_dejson (airflow.models.connection.Connection property) EXTRA_KEY (airflow.models.connection.Connection attribute) extract() (in module airflow.example_dags.tutorial_dag)

F

failure_callable() (in module airflow.example_dags.example_sensors) FailureTrigger (class in airflow.triggers.testing) Feature releases file (airflow.models.dagbag.FileLoadStat attribute) FILE_PARSERS (in module airflow.secrets.local_filesystem) FileLoadStat (class in airflow.models.dagbag) fileloc (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) filepath (airflow.models.dag.DAG property) FileSensor (class in airflow.sensors.filesystem) FileSyntaxError (class in airflow.exceptions) FileTrigger (class in airflow.triggers.file) filter_for_tis() (airflow.models.taskinstance.TaskInstance static method) FLASK_APP

folder (airflow.models.dag.DAG property) following_schedule() (airflow.models.dag.DAG method) 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.taskinstance.SimpleTaskInstance class method) from_json() (airflow.models.connection.Connection class method) from_ti() (airflow.models.taskinstance.SimpleTaskInstance class method) FSHook (class in airflow.hooks.filesystem) full_filepath (airflow.models.dag.DAG property) function (airflow.decorators.base.ExpandableFactory attribute) (airflow.decorators.base.Task attribute) function_signature() (airflow.decorators.base.ExpandableFactory method)

G

generate_command() (airflow.models.taskinstance.TaskInstance static method) generate_run_id() (airflow.timetables.base.Timetable method) (airflow.timetables.simple.DatasetTriggeredTimetable method) generate_value() (in module airflow.example_dags.example_xcomargs) GenericTransfer (class in airflow.operators.generic_transfer) get() (airflow.models.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_concurrency_reached() (airflow.models.dag.DAG method) get_config() (airflow.secrets.base_secrets.BaseSecretsBackend method) get_conn() (airflow.hooks.base.BaseHook method) (airflow.hooks.filesystem.FSHook method) get_conn_uri() (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.secrets.environment_variables.EnvironmentVariablesBackend method) get_conn_value() (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.secrets.environment_variables.EnvironmentVariablesBackend method) get_connection() (airflow.hooks.base.BaseHook class method) (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.secrets.local_filesystem.LocalFilesystemBackend method) (airflow.secrets.metastore.MetastoreBackend method) get_connection_form_widgets() (airflow.hooks.base.BaseHook class method) (airflow.hooks.base.DiscoverableHook static method) get_connection_from_secrets() (airflow.models.connection.Connection class method) get_connection_parameter_names() (in module airflow.secrets.local_filesystem) get_connections() (airflow.hooks.base.BaseHook class method) (airflow.secrets.base_secrets.BaseSecretsBackend method) (airflow.secrets.local_filesystem.LocalFilesystemBackend method) (airflow.secrets.metastore.MetastoreBackend method) get_count() (airflow.sensors.external_task.ExternalTaskSensor method) get_current() (airflow.models.dag.DagModel class method) get_current_context() (in module airflow.operators.python) get_current_dag() (airflow.models.dag.DagContext class method) get_dag() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dagbag.DagBag method) get_dagmodel() (airflow.models.dag.DagModel static method) get_dagrun() (airflow.models.dag.DAG method) (airflow.models.taskinstance.TaskInstance method) get_dagruns_between() (airflow.models.dag.DAG method) get_dataset_triggered_next_run_info() (airflow.models.dag.DagModel method) (in module airflow.models.dag) get_default_view() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) get_direct_relatives() (airflow.models.baseoperator.BaseOperator method) get_doc_md() (airflow.models.dag.DAG method) get_edge_info() (airflow.models.dag.DAG method) get_email_subject_content() (airflow.models.taskinstance.TaskInstance method) get_env() (airflow.operators.bash.BashOperator method) get_external_task_group_task_ids() (airflow.sensors.external_task.ExternalTaskSensor method) get_extra() (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_inlet_defs() (airflow.models.baseoperator.BaseOperator method)

get_is_active() (airflow.models.dag.DAG method) get_is_paused() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) get_last_dagrun() (airflow.models.dag.DAG method) (airflow.models.dag.DagModel method) (in module airflow.models.dag) get_latest_execution_date() (airflow.models.dag.DAG method) get_link() (airflow.models.baseoperator.BaseOperatorLink method) (airflow.operators.trigger_dagrun.TriggerDagRunLink method) (airflow.sensors.external_task.ExternalDagLink method) get_merged_defaults() (in module airflow.models.baseoperator) get_names() (in module airflow.example_dags.example_params_trigger_ui) get_next_data_interval() (airflow.models.dag.DAG method) get_next_workday() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method) get_num_active_runs() (airflow.models.dag.DAG method) get_num_running_task_instances() (airflow.models.taskinstance.TaskInstance method) get_num_task_instances() (airflow.models.dag.DAG static method) get_outlet_defs() (airflow.models.baseoperator.BaseOperator method) get_param() (airflow.models.param.ParamsDict method) get_password() (airflow.models.connection.Connection method) get_path() (airflow.hooks.filesystem.FSHook method) get_paused_dag_ids() (airflow.models.dag.DagModel static method) get_previous_dagrun() (airflow.models.taskinstance.TaskInstance method) get_previous_execution_date() (airflow.models.taskinstance.TaskInstance 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_k8s_spec() (airflow.models.taskinstance.TaskInstance method) get_rendered_template_fields() (airflow.models.taskinstance.TaskInstance method) get_run_data_interval() (airflow.models.dag.DAG method) get_run_dates() (airflow.models.dag.DAG method) get_serialized_fields() (airflow.models.baseoperator.BaseOperator class method) (airflow.models.dag.DAG class method) (airflow.sensors.base.BaseSensorOperator class method) (airflow.sensors.external_task.ExternalTaskMarker class method) get_task() (airflow.models.dag.DAG method) get_task_instances() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) get_task_instances_before() (airflow.models.dag.DAG method) get_template_context() (airflow.models.taskinstance.TaskInstance method) get_template_env() (airflow.models.dag.DAG method) get_truncated_error_traceback() (airflow.models.taskinstance.TaskInstance static method) get_ui_field_behaviour() (airflow.hooks.base.BaseHook class method) (airflow.hooks.base.DiscoverableHook static method) get_unique_task_id() (in module airflow.decorators.base) 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.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)

H

handle_callback() (airflow.models.dag.DAG method) handle_failure() (airflow.models.taskinstance.TaskInstance method) has_dag() (airflow.models.baseoperator.BaseOperator method) has_dag_runs() (airflow.models.dag.DAG method) has_import_errors (airflow.models.dag.DagModel attribute) has_task() (airflow.models.dag.DAG method) has_task_concurrency_limits (airflow.models.dag.DagModel attribute)

has_task_group() (airflow.models.dag.DAG method) has_value (airflow.models.param.Param property) 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) hybrid_property (in module airflow.models.taskinstance)

I

id (airflow.models.connection.Connection attribute) (airflow.models.variable.Variable attribute) InconsistentDataInterval infer_automated_data_interval() (airflow.models.dag.DAG method) infer_manual_data_interval() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method) (airflow.timetables.base.Timetable method) (airflow.timetables.events.EventsTimetable method) (airflow.timetables.interval.CronDataIntervalTimetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) (airflow.timetables.trigger.CronTriggerTimetable method) ingest (in module airflow.example_dags.example_branch_labels) inherits_from_empty_operator (airflow.models.baseoperator.BaseOperator property) (airflow.operators.empty.EmptyOperator attribute) init_on_load() (airflow.models.taskinstance.TaskInstance method) (airflow.models.xcom.BaseXCom method) init_run_context() (airflow.models.taskinstance.TaskInstance method) insert_mapping() (airflow.models.taskinstance.TaskInstance static method) interval() (airflow.timetables.base.DagRunInfo 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_fixed_time_schedule() (airflow.models.dag.DAG method) is_paused (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) is_paused_at_creation (airflow.models.dag.DagModel attribute) is_premature (airflow.models.taskinstance.TaskInstance property) is_subdag (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) is_trigger_log_context (airflow.models.taskinstance.TaskInstance attribute) items() (airflow.models.param.ParamsDict method) iter_dagrun_infos_between() (airflow.models.dag.DAG method) iter_invalid_owner_links() (airflow.models.dag.DAG method) iter_references() (airflow.models.param.DagParam method)

J

job_id (airflow.models.taskinstance.TaskInstance attribute)

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.taskinstance.TaskInstanceKey property) (airflow.models.variable.Variable attribute) (airflow.models.xcom.BaseXCom attribute)

L

last_expired (airflow.models.dag.DagModel attribute) last_parsed_time (airflow.models.dag.DagModel attribute) last_pickled (airflow.models.dag.DagModel attribute) latest (airflow.timetables.base.TimeRestriction attribute) latest_execution_date (airflow.models.dag.DAG property) latest_only (in module airflow.example_dags.example_latest_only) (in module airflow.example_dags.example_latest_only_with_trigger) LatestOnlyOperator (class in airflow.operators.latest_only) LazyXComAccess (class in airflow.models.xcom) leaves (airflow.models.baseoperator.BaseOperator property) (airflow.models.dag.DAG property) line_no (airflow.exceptions.FileSyntaxError attribute) link (airflow.models.dag.DagOwnerAttributes attribute) listeners (airflow.example_dags.plugins.listener_plugin.MetadataCollectionPlugin attribute) load_connections() (in module airflow.secrets.local_filesystem) 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_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) log_info() (airflow.models.connection.Connection method) log_url (airflow.models.taskinstance.TaskInstance property) logger (in module airflow.models.baseoperator) (in module airflow.models.param) logical_date (airflow.timetables.base.DagRunInfo property) login (airflow.models.connection.Connection attribute)

M

Major release map_index (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.xcom.BaseXCom attribute) mark_success_url (airflow.models.taskinstance.TaskInstance property) max_active_runs (airflow.models.dag.DagModel attribute) max_active_tasks (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) max_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 airflow.decorators airflow.decorators.base airflow.decorators.branch_python 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_bash_operator airflow.example_dags.example_branch_datetime_operator airflow.example_dags.example_branch_day_of_week_operator airflow.example_dags.example_branch_labels airflow.example_dags.example_branch_operator airflow.example_dags.example_branch_operator_decorator airflow.example_dags.example_branch_python_dop_operator_3 airflow.example_dags.example_complex airflow.example_dags.example_datasets airflow.example_dags.example_dynamic_task_mapping airflow.example_dags.example_external_task_marker_dag airflow.example_dags.example_kubernetes_executor airflow.example_dags.example_latest_only airflow.example_dags.example_latest_only_with_trigger airflow.example_dags.example_local_kubernetes_executor airflow.example_dags.example_nested_branch_dag airflow.example_dags.example_params_trigger_ui airflow.example_dags.example_params_ui_tutorial airflow.example_dags.example_passing_params_via_test_command 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_subdag_operator airflow.example_dags.example_task_group airflow.example_dags.example_task_group_decorator airflow.example_dags.example_time_delta_sensor_async airflow.example_dags.example_trigger_controller_dag airflow.example_dags.example_trigger_target_dag airflow.example_dags.example_xcom airflow.example_dags.example_xcomargs airflow.example_dags.libs airflow.example_dags.libs.helper airflow.example_dags.plugins airflow.example_dags.plugins.event_listener airflow.example_dags.plugins.listener_plugin airflow.example_dags.plugins.workday airflow.example_dags.subdags airflow.example_dags.subdags.subdag airflow.example_dags.tutorial airflow.example_dags.tutorial_dag airflow.example_dags.tutorial_taskflow_api airflow.example_dags.tutorial_taskflow_api_virtualenv airflow.exceptions airflow.hooks airflow.hooks.base airflow.hooks.dbapi airflow.hooks.filesystem airflow.hooks.subprocess airflow.macros airflow.models.baseoperator airflow.models.connection airflow.models.dag airflow.models.dagbag airflow.models.param airflow.models.taskinstance airflow.models.variable airflow.models.xcom airflow.operators airflow.operators.bash airflow.operators.branch airflow.operators.datetime airflow.operators.email airflow.operators.empty airflow.operators.generic_transfer airflow.operators.latest_only airflow.operators.python airflow.operators.smooth airflow.operators.subdag airflow.operators.trigger_dagrun airflow.operators.weekday airflow.policies airflow.secrets airflow.secrets.base_secrets airflow.secrets.environment_variables airflow.secrets.local_filesystem airflow.secrets.metastore airflow.sensors airflow.sensors.base airflow.sensors.bash airflow.sensors.date_time airflow.sensors.external_task airflow.sensors.filesystem airflow.sensors.python airflow.sensors.time_delta airflow.sensors.time_sensor airflow.sensors.weekday airflow.timetables airflow.timetables._cron airflow.timetables.base airflow.timetables.events airflow.timetables.interval airflow.timetables.simple airflow.timetables.trigger airflow.triggers airflow.triggers.base airflow.triggers.external_task airflow.triggers.file airflow.triggers.temporal airflow.triggers.testing

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

N

name (airflow.example_dags.plugins.listener_plugin.MetadataCollectionPlugin attribute) (airflow.example_dags.plugins.workday.WorkdayTimetablePlugin attribute) (airflow.models.baseoperator.BaseOperatorLink property) (airflow.models.dag.DagTag attribute) (airflow.operators.trigger_dagrun.TriggerDagRunLink attribute) (airflow.sensors.external_task.ExternalDagLink attribute) next_dagrun (airflow.models.dag.DagModel attribute) next_dagrun_after_date() (airflow.models.dag.DAG method) next_dagrun_create_after (airflow.models.dag.DagModel attribute) next_dagrun_data_interval (airflow.models.dag.DagModel property) next_dagrun_data_interval_end (airflow.models.dag.DagModel attribute) next_dagrun_data_interval_start (airflow.models.dag.DagModel attribute) next_dagrun_info() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method) (airflow.models.dag.DAG method) (airflow.timetables.base.Timetable method) (airflow.timetables.events.EventsTimetable method) (airflow.timetables.simple.ContinuousTimetable method) (airflow.timetables.simple.NullTimetable method) (airflow.timetables.simple.OnceTimetable method) (airflow.timetables.trigger.CronTriggerTimetable method)

next_kwargs (airflow.models.taskinstance.TaskInstance attribute) next_method (airflow.models.taskinstance.TaskInstance attribute) next_retry_datetime() (airflow.models.taskinstance.TaskInstance method) next_try_number (airflow.models.taskinstance.TaskInstance property) NoAvailablePoolSlot normal (in module airflow.example_dags.example_setup_teardown) normalize_schedule() (airflow.models.dag.DAG method) normalized_schedule_interval (airflow.models.dag.DAG property) note (airflow.models.taskinstance.TaskInstance attribute) 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_kill() (airflow.models.baseoperator.BaseOperator method) (airflow.operators.bash.BashOperator method) 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_class (airflow.models.baseoperator.BaseOperator property) operator_extra_links (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.sensors.external_task.ExternalTaskMarker attribute) (airflow.sensors.external_task.ExternalTaskSensor attribute)

operator_name (airflow.models.baseoperator.BaseOperator property) operators (airflow.models.baseoperator.BaseOperatorLink attribute) OperatorSubclass (in module airflow.decorators.base) ORIENTATION_PRESETS (in module airflow.models.dag) orm_deserialize_value() (airflow.models.xcom.BaseXCom method) output (airflow.models.baseoperator.BaseOperator property) 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.DAG property) (airflow.models.dag.DagOwnerAttributes attribute) owners (airflow.models.dag.DagModel attribute)

P

Param (class in airflow.models.param) param() (airflow.models.dag.DAG method) ParamsDict (class in airflow.models.param) ParamValidationError parent_dag (airflow.models.dag.DAG attribute) (airflow.models.dag.DagModel attribute) parent_task (in module airflow.example_dags.example_external_task_marker_dag) parse_from_uri() (airflow.models.connection.Connection method) parse_netloc_to_hostname() (in module airflow.models.connection) parse_retries() (in module airflow.models.baseoperator) partial (airflow.models.baseoperator.BaseOperator attribute) partial() (airflow.decorators.base.Task method) (in module airflow.models.baseoperator) partial_subset() (airflow.models.dag.DAG method) 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_python_operator) periodic (airflow.timetables.base.Timetable attribute) pickle() (airflow.models.dag.DAG method) pickle_id (airflow.models.dag.DAG property) (airflow.models.dag.DagModel attribute) pickle_info() (airflow.models.dag.DAG method) pid (airflow.models.taskinstance.TaskInstance attribute) pod_mutation_hook() (in module airflow.policies) PodMutationHookException PodReconciliationError poke() (airflow.operators.subdag.SubDagOperator method) (airflow.sensors.base.BaseSensorOperator method) (airflow.sensors.bash.BashSensor method) (airflow.sensors.date_time.DateTimeSensor method) (airflow.sensors.external_task.ExternalTaskSensor method) (airflow.sensors.filesystem.FileSensor method) (airflow.sensors.python.PythonSensor method) (airflow.sensors.time_delta.TimeDeltaSensor method) (airflow.sensors.time_sensor.TimeSensor method) (airflow.sensors.weekday.DayOfWeekSensor method) poke_mode_only() (in module airflow.sensors.base)

PokeReturnValue (class in airflow.sensors.base) pool (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.taskinstance.TaskInstance attribute) pool_slots (airflow.models.taskinstance.TaskInstance attribute) PoolNotFound pop_context_managed_dag() (airflow.models.dag.DagContext class method) port (airflow.models.connection.Connection attribute) post_execute() (airflow.models.baseoperator.BaseOperator method) (airflow.operators.subdag.SubDagOperator method) pre_execute() (airflow.models.baseoperator.BaseOperator method) (airflow.operators.subdag.SubDagOperator method) prepare_for_execution() (airflow.models.baseoperator.BaseOperator method) (airflow.sensors.base.BaseSensorOperator method) prev_attempted_tries (airflow.models.taskinstance.TaskInstance property) previous_schedule() (airflow.models.dag.DAG method) previous_start_date_success (airflow.models.taskinstance.TaskInstance property) previous_ti (airflow.models.taskinstance.TaskInstance property) previous_ti_success (airflow.models.taskinstance.TaskInstance property) primary (airflow.models.taskinstance.TaskInstanceKey property) print_context() (in module airflow.example_dags.example_python_operator) print_env_vars() (in module airflow.example_dags.example_passing_params_via_test_command) print_stuff() (in module airflow.example_dags.libs.helper) print_value() (in module airflow.example_dags.example_xcomargs) priority_weight (airflow.models.taskinstance.TaskInstance attribute) process_file() (airflow.models.dagbag.DagBag method) process_params() (in module airflow.models.param) processor_subdir (airflow.models.dag.DagModel attribute) pull_value_from_bash_push() (in module airflow.example_dags.example_xcom) puller() (in module airflow.example_dags.example_xcom) push() (in module airflow.example_dags.example_xcom) push_by_returning() (in module airflow.example_dags.example_xcom) push_context_managed_dag() (airflow.models.dag.DagContext class method) python (airflow.decorators.TaskDecoratorCollection attribute) python_callable (airflow.decorators.base.DecoratedMappedOperator attribute) python_task() (in module airflow.decorators.python) 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

queue (airflow.models.taskinstance.TaskInstance attribute)

queued_by_job_id (airflow.models.taskinstance.TaskInstance attribute) queued_dttm (airflow.models.taskinstance.TaskInstance attribute)

R

random() (in module airflow.macros) ready_for_retry() (airflow.models.taskinstance.TaskInstance method) reduced (airflow.models.taskinstance.TaskInstanceKey property) refresh_from_db() (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) RemovedInAirflow3Warning render_k8s_pod_yaml() (airflow.models.taskinstance.TaskInstance method) render_template_fields() (airflow.models.baseoperator.BaseOperator method) render_templates() (airflow.models.taskinstance.TaskInstance method) rendered_task_instance_fields (airflow.models.taskinstance.TaskInstance attribute) reschedule (airflow.sensors.base.BaseSensorOperator property) resolve() (airflow.models.param.DagParam method) (airflow.models.param.Param method) resolve_template_files() (airflow.models.dag.DAG method) resolve_xcom_backend() (in module airflow.models.xcom) root_dag_id (airflow.models.dag.DagModel attribute) root_setup() (in module airflow.example_dags.example_setup_teardown_taskflow) roots (airflow.models.baseoperator.BaseOperator property) (airflow.models.dag.DAG property) rotate_fernet_key() (airflow.models.connection.Connection method) (airflow.models.variable.Variable method)

run() (airflow.models.baseoperator.BaseOperator method) (airflow.models.dag.DAG method) (airflow.models.taskinstance.TaskInstance method) (airflow.triggers.base.BaseTrigger method) (airflow.triggers.external_task.DagStateTrigger method) (airflow.triggers.external_task.TaskStateTrigger method) (airflow.triggers.file.FileTrigger method) (airflow.triggers.temporal.DateTimeTrigger method) (airflow.triggers.testing.FailureTrigger method) (airflow.triggers.testing.SuccessTrigger method) run_after (airflow.timetables.base.DagRunInfo attribute) run_command() (airflow.hooks.subprocess.SubprocessHook method) run_id (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceKey attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.xcom.BaseXCom attribute) 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)

S

safe_dag_id (airflow.models.dag.DagModel property) schedule_dataset_references (airflow.models.dag.DagModel attribute) schedule_datasets (airflow.models.dag.DagModel attribute) schedule_downstream_tasks() (airflow.models.taskinstance.TaskInstance method) schedule_interval (airflow.models.dag.DagModel attribute) ScheduleArg (in module airflow.models.dag) ScheduleInterval (in module airflow.models.baseoperator) (in module airflow.models.dag) ScheduleIntervalArg (in module airflow.models.dag) scheduler_lock (airflow.models.dag.DagModel attribute) schema (airflow.models.connection.Connection attribute) send_sigterm() (airflow.hooks.subprocess.SubprocessHook method) sensor (airflow.decorators.TaskDecoratorCollection attribute) sensor_task() (in module airflow.decorators.sensor) SerializationError serialize() (airflow.models.param.Param method) (airflow.models.param.ParamsDict 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.external_task.DagStateTrigger method) (airflow.triggers.external_task.TaskStateTrigger method) (airflow.triggers.file.FileTrigger method) (airflow.triggers.temporal.DateTimeTrigger 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) set_current_context() (in module airflow.models.taskinstance) set_dag_runs_state() (airflow.models.dag.DAG method) set_dependency() (airflow.models.dag.DAG method) set_duration() (airflow.models.taskinstance.TaskInstance method) set_edge_info() (airflow.models.dag.DAG method) set_extra() (airflow.models.connection.Connection method) set_is_paused() (airflow.models.dag.DagModel method) set_password() (airflow.models.connection.Connection method) set_state() (airflow.models.taskinstance.TaskInstance method) set_task_instance_state() (airflow.models.dag.DAG method) set_val() (airflow.models.variable.Variable method) set_xcomargs_dependencies() (airflow.models.baseoperator.BaseOperator 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) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.python.PythonOperator attribute)

short_circuit (airflow.decorators.TaskDecoratorCollection attribute) short_circuit_task() (in module airflow.decorators.short_circuit) ShortCircuitOperator (class in airflow.operators.python) 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) SkippedStatePropagationOptions (class in airflow.operators.subdag) SLAMissCallback (in module airflow.models.dag) SmoothOperator (class in airflow.operators.smooth) start (airflow.timetables.base.DataInterval attribute) (in module airflow.example_dags.example_subdag_operator) (in module airflow.example_dags.example_task_group) start_date (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.taskinstance.TaskInstance attribute) (in module airflow.example_dags.example_external_task_marker_dag) start_task (in module airflow.example_dags.example_task_group_decorator) start_task_executor_config (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor) state (airflow.models.taskinstance.TaskInstance attribute) status_code (airflow.exceptions.AirflowBadRequest attribute) (airflow.exceptions.AirflowException attribute) (airflow.exceptions.AirflowNotFoundException attribute) store_serialized_dags (airflow.models.dagbag.DagBag property) sub_dag() (airflow.models.dag.DAG method) subdag (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.subdag.SubDagOperator attribute) subdag() (in module airflow.example_dags.subdags.subdag) SubDagOperator (class in airflow.operators.subdag) subdags (airflow.models.dag.DAG property) subprocess_hook() (airflow.operators.bash.BashOperator method) SubprocessHook (class in airflow.hooks.subprocess) SubprocessResult (in module airflow.hooks.subprocess) success_callable() (in module airflow.example_dags.example_sensors) SuccessTrigger (class in airflow.triggers.testing) summary (airflow.timetables._cron.CronMixin property) (airflow.timetables.base.Timetable property) (airflow.timetables.events.EventsTimetable property) (airflow.timetables.interval.DeltaDataIntervalTimetable property) (airflow.timetables.simple.ContinuousTimetable property) (airflow.timetables.simple.DatasetTriggeredTimetable property) (airflow.timetables.simple.NullTimetable property) (airflow.timetables.simple.OnceTimetable property) supports_lineage (airflow.models.baseoperator.BaseOperator attribute) 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) target_times_as_dates() (in module airflow.operators.datetime) task (airflow.models.dag.DAG property) (airflow.models.taskinstance.TaskInstance attribute) Task (class in airflow.decorators.base) task (in module airflow.decorators) task() (in module airflow.operators.python) task_1() (in module airflow.example_dags.example_task_group_decorator) task_2() (in module airflow.example_dags.example_task_group_decorator) task_3() (in module airflow.example_dags.example_task_group_decorator) task_decorator_factory() (in module airflow.decorators.base) task_end() (in module airflow.example_dags.example_task_group_decorator) task_group (airflow.models.baseoperator.BaseOperator attribute) (airflow.models.dag.DAG property) task_group() (in module airflow.decorators.task_group) task_group_dict() (airflow.models.dag.DAG method) 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.TaskInstanceKey attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) (airflow.models.xcom.BaseXCom attribute) task_ids (airflow.models.dag.DAG property) task_instance (airflow.models.taskinstance.TaskInstanceNote attribute) task_instance_mutation_hook() (in module airflow.policies) task_instance_note (airflow.models.taskinstance.TaskInstance attribute) task_num (airflow.models.dagbag.FileLoadStat attribute) task_outlet_dataset_references (airflow.models.dag.DagModel attribute) task_policy() (in module airflow.policies) task_start() (in module airflow.example_dags.example_task_group_decorator) task_type (airflow.models.baseoperator.BaseOperator property) TaskAlreadyInTaskGroup TaskConcurrencyLimitReached TaskDecorator (class in airflow.decorators.base) TaskDecoratorCollection (class in airflow.decorators) TaskDeferralError TaskDeferred TaskInstance (class in airflow.models.taskinstance) TaskInstanceKey (class in airflow.models.taskinstance) TaskInstanceNote (class in airflow.models.taskinstance) TaskInstanceNotFound TaskInstanceStateType (in module airflow.models.taskinstance) TaskNotFound TaskPostExecuteHook (in module airflow.models.baseoperator) TaskPreExecuteHook (in module airflow.models.baseoperator) TaskReturnCode (class in airflow.models.taskinstance) tasks (airflow.models.dag.DAG property) TaskStateTrigger (class in airflow.triggers.external_task) teardown (in module airflow.decorators) teardown_task() (in module airflow.decorators.setup_teardown) template_ext (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.bash.BashOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.python.PythonVirtualenvOperator attribute)

template_fields (airflow.decorators.base.DecoratedOperator attribute) (airflow.decorators.sensor.DecoratedSensorOperator 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.ExternalPythonOperator attribute) (airflow.operators.python.PythonOperator attribute) (airflow.operators.python.PythonVirtualenvOperator attribute) (airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.sensors.bash.BashSensor attribute) (airflow.sensors.date_time.DateTimeSensor attribute) (airflow.sensors.external_task.ExternalTaskMarker attribute) (airflow.sensors.external_task.ExternalTaskSensor attribute) (airflow.sensors.filesystem.FileSensor attribute) (airflow.sensors.python.PythonSensor attribute) template_fields_renderers (airflow.decorators.base.DecoratedOperator attribute) (airflow.decorators.sensor.DecoratedSensorOperator 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.trigger_dagrun.TriggerDagRunOperator attribute) test() (airflow.models.dag.DAG method) test_connection() (airflow.models.connection.Connection method) this_will_skip (in module airflow.example_dags.example_bash_operator) ti_selector_condition() (airflow.models.taskinstance.TaskInstance class method) TimeDeltaSensor (class in airflow.sensors.time_delta) TimeDeltaSensorAsync (class in airflow.sensors.time_delta) TimeDeltaTrigger (class in airflow.triggers.temporal) TimeRestriction (class in airflow.timetables.base) TimeSensor (class in airflow.sensors.time_sensor) TimeSensorAsync (class in airflow.sensors.time_sensor) timestamp (airflow.models.xcom.BaseXCom attribute) Timetable (class in airflow.timetables.base) timetable_description (airflow.models.dag.DagModel attribute) timetables (airflow.example_dags.plugins.workday.WorkdayTimetablePlugin attribute) timezone (airflow.models.dag.DagModel property) topological_sort() (airflow.models.dag.DAG method) TR (in module airflow.models.taskinstance) tree_view() (airflow.models.dag.DAG method) trigger (airflow.models.taskinstance.TaskInstance attribute) (in module airflow.example_dags.example_trigger_controller_dag) trigger_id (airflow.models.taskinstance.TaskInstance attribute) trigger_timeout (airflow.models.taskinstance.TaskInstance attribute) TriggerDagRunLink (class in airflow.operators.trigger_dagrun) TriggerDagRunOperator (class in airflow.operators.trigger_dagrun) triggerer_job (airflow.models.taskinstance.TaskInstance attribute) TriggerEvent (class in airflow.triggers.base) try_number (airflow.models.taskinstance.TaskInstance property) (airflow.models.taskinstance.TaskInstanceKey attribute) tutorial_etl_dag (in module airflow.example_dags.example_sensor_decorator) tutorial_taskflow_api() (in module airflow.example_dags.tutorial_taskflow_api) tutorial_taskflow_api_virtualenv() (in module airflow.example_dags.tutorial_taskflow_api_virtualenv)

U

ui_color (airflow.example_dags.example_skip_dag.EmptySkipOperator attribute) (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.bash.BashOperator attribute) (airflow.operators.email.EmailOperator attribute) (airflow.operators.empty.EmptyOperator attribute) (airflow.operators.generic_transfer.GenericTransfer attribute) (airflow.operators.latest_only.LatestOnlyOperator attribute) (airflow.operators.python.PythonOperator attribute) (airflow.operators.smooth.SmoothOperator attribute) (airflow.operators.subdag.SubDagOperator attribute) (airflow.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.sensors.base.BaseSensorOperator attribute) (airflow.sensors.external_task.ExternalTaskMarker attribute) (airflow.sensors.external_task.ExternalTaskSensor attribute) (airflow.sensors.filesystem.FileSensor attribute)

ui_fgcolor (airflow.models.baseoperator.BaseOperator attribute) (airflow.operators.subdag.SubDagOperator attribute) unixname (airflow.models.taskinstance.TaskInstance attribute) unmap() (airflow.models.baseoperator.BaseOperator method) UnmappableOperator UnmappableXComLengthPushed UnmappableXComTypePushed update() (airflow.models.param.ParamsDict method) (airflow.models.variable.Variable static method) updated_at (airflow.models.taskinstance.TaskInstance attribute) (airflow.models.taskinstance.TaskInstanceNote attribute) user_id (airflow.models.taskinstance.TaskInstanceNote attribute)

V

val (airflow.models.variable.Variable property) valid_modes (airflow.sensors.base.BaseSensorOperator attribute) validate() (airflow.models.dag.DAG method) (airflow.models.param.ParamsDict method) (airflow.timetables._cron.CronMixin method) (airflow.timetables.base.Timetable method) (airflow.timetables.interval.DeltaDataIntervalTimetable method) validate_schedule_and_params() (airflow.models.dag.DAG 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) virtualenv (airflow.decorators.TaskDecoratorCollection attribute) virtualenv_task() (in module airflow.decorators.python_virtualenv)

W

wait (in module airflow.example_dags.example_time_delta_sensor_async) with_try_number() (airflow.models.taskinstance.TaskInstanceKey method) WorkdayTimetablePlugin (class in airflow.example_dags.plugins.workday)

worker_container_repository (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor) worker_container_tag (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor)

X

x() (in module airflow.example_dags.example_python_operator) XCom (in module airflow.models.xcom) XCOM_EXECUTION_DATE_ISO (in module airflow.operators.trigger_dagrun) xcom_pull() (airflow.models.baseoperator.BaseOperator static method) (airflow.models.taskinstance.TaskInstance method)

xcom_push() (airflow.models.baseoperator.BaseOperator static method) (airflow.models.taskinstance.TaskInstance method) XCOM_RUN_ID (in module airflow.operators.trigger_dagrun) XComForMappingNotPushed XComNotFound

Y

yt_link (airflow.operators.smooth.SmoothOperator attribute)

PreviousNext

Was this entry helpful?