• Home
• Index

Index

_

__getattr__() (in module airflow.exceptions) (in module airflow.utils.state) __repr__() (airflow.timetables.events.EventsTimetable method) (airflow.triggers.base.BaseTrigger method) (airflow.triggers.base.TriggerEvent method) __str__() (airflow.exceptions.AirflowDagDuplicatedIdException method) (airflow.exceptions.AirflowFileParseException method) (airflow.exceptions.DeserializingResultError method) (airflow.exceptions.FileSyntaxError method) (airflow.utils.state.DagRunState method) (airflow.utils.state.IntermediateTIState method) (airflow.utils.state.TaskInstanceState method) (airflow.utils.state.TerminalTIState method)

A

active_runs_limit (airflow.timetables.assets.AssetOrTimeSchedule attribute) (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.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_branch_labels module airflow.example_dags.example_branch_python_dop_operator_3 module airflow.example_dags.example_complex module airflow.example_dags.example_custom_weight 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_inlet_event_extra module airflow.example_dags.example_kubernetes_executor 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_setup_teardown module airflow.example_dags.example_setup_teardown_taskflow module airflow.example_dags.example_simplest_dag 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_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.policies module airflow.sdk.execution_time.macros module airflow.secrets module airflow.secrets.base_secrets module airflow.secrets.environment_variables module airflow.secrets.local_filesystem module airflow.secrets.metastore module airflow.timetables module airflow.timetables.assets module airflow.timetables.base module airflow.timetables.datasets 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.callback 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 AirflowClearRunningTaskException AirflowClusterPolicyError AirflowClusterPolicySkipDag AirflowClusterPolicyViolation AirflowDagDuplicatedIdException AirflowException AirflowFileParseException AirflowOptionalProviderFeatureException AirflowProviderDeprecationWarning AirflowUnsupportedFileTypeException API (in module airflow.example_dags.tutorial_objectstorage) aq_fields (in module airflow.example_dags.tutorial_objectstorage) 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) (airflow.timetables.simple.PartitionedAssetTimetable 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)

B

base (in module airflow.example_dags.tutorial_objectstorage) BaseEventTrigger (class in airflow.triggers.base) BaseTrigger (class in airflow.triggers.base)

bash_op1 (in module airflow.example_dags.example_xcomargs) bash_push (in module airflow.example_dags.example_xcom) branch() (in module airflow.example_dags.example_nested_branch_dag)

C

callback_kwargs (airflow.triggers.callback.CallbackTrigger attribute) callback_path (airflow.triggers.callback.CallbackTrigger attribute) CallbackTrigger (class in airflow.triggers.callback) can_be_scheduled (airflow.timetables.assets.AssetOrTimeSchedule attribute) (airflow.timetables.base.Timetable attribute) (airflow.timetables.simple.NullTimetable attribute) catchup (airflow.timetables.base.TimeRestriction attribute) cleanup() (airflow.triggers.base.BaseTrigger method) color() (airflow.utils.state.State class method) color_fg() (airflow.utils.state.State class method) cond (in module airflow.example_dags.example_branch_python_dop_operator_3) configs_file (airflow.secrets.local_filesystem.LocalFilesystemBackend attribute) CONN_ENV_PREFIX (in module airflow.secrets.environment_variables)

conn_name_attr (airflow.hooks.base.DiscoverableHook attribute) conn_type (airflow.hooks.base.DiscoverableHook attribute) ConnectionNotUnique connections_file (airflow.secrets.local_filesystem.LocalFilesystemBackend attribute) 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) ContinuousTimetable (class in airflow.timetables.simple) create_entry_group (in module airflow.example_dags.example_complex) create_test_pipeline() (in module airflow.example_dags.example_skip_dag) CronDataIntervalTimetable (class in airflow.timetables.interval) CronTriggerTimetable (class in airflow.timetables.trigger)

D

dag1_asset (in module airflow.example_dags.example_assets) dag2_asset (in module airflow.example_dags.example_assets) dag3_asset (in module airflow.example_dags.example_assets) dag_id (airflow.exceptions.AirflowDagDuplicatedIdException attribute) (airflow.exceptions.DeserializationError attribute) dag_policy() (in module airflow.policies) dag_run (airflow.exceptions.DagRunAlreadyExists attribute) dag_states (airflow.utils.state.State attribute) DagCodeNotFound DagNotFound DagRunAlreadyExists DagRunInfo (class in airflow.timetables.base) DagRunNotFound DagRunState (class in airflow.utils.state) data_interval (airflow.timetables.base.DagRunInfo attribute) DataInterval (class in airflow.timetables.base) DatasetOrTimeSchedule (class in airflow.timetables.datasets) datetime_diff_for_humans() (in module airflow.sdk.execution_time.macros) 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_SECRETS_SEARCH_PATH (in module airflow.secrets) DEFERRED (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) Delta (in module airflow.timetables.interval)

DeltaDataIntervalTimetable (class in airflow.timetables.interval) DeltaTriggerTimetable (class in airflow.timetables.trigger) deprecated_provider_since (airflow.exceptions.AirflowProviderDeprecationWarning attribute) deprecated_since (airflow.exceptions.RemovedInAirflow4Warning attribute) description (airflow.timetables.assets.AssetOrTimeSchedule attribute) (airflow.timetables.base.Timetable attribute) (airflow.timetables.simple.ContinuousTimetable attribute) (airflow.timetables.simple.NullTimetable attribute) (airflow.timetables.simple.OnceTimetable attribute) (airflow.timetables.trigger.MultipleCronTriggerTimetable attribute) DeserializationError deserialize() (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.simple.PartitionedAssetTimetable class method) (airflow.timetables.simple.PartitionMapper class method) (airflow.timetables.trigger.CronTriggerTimetable class method) (airflow.timetables.trigger.DeltaTriggerTimetable class method) (airflow.timetables.trigger.MultipleCronTriggerTimetable class method) DeserializingResultError DiscoverableHook (class in airflow.hooks.base) DiscrimatedTriggerEvent (in module airflow.triggers.base) ds_add() (in module airflow.sdk.execution_time.macros) ds_format() (in module airflow.sdk.execution_time.macros) ds_format_locale() (in module airflow.sdk.execution_time.macros)

E

earliest (airflow.timetables.base.TimeRestriction attribute) EmptySkipOperator (class in airflow.example_dags.example_skip_dag) end (airflow.timetables.base.DataInterval 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]

EnvironmentVariablesBackend (class in airflow.secrets.environment_variables) event_dates (airflow.timetables.events.EventsTimetable attribute) 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_display_name) example_display_name() (in module airflow.example_dags.example_display_name) example_simplest_dag() (in module airflow.example_dags.example_simplest_dag) execute() (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) existing (airflow.exceptions.AirflowDagDuplicatedIdException attribute) extract() (in module airflow.example_dags.tutorial_dag)

F

FAILED (airflow.utils.state.DagRunState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute) failed_states (airflow.utils.state.State attribute) FailureTrigger (class in airflow.triggers.testing) Feature releases

FILE_PARSERS (in module airflow.secrets.local_filesystem) file_path (airflow.exceptions.AirflowFileParseException attribute) (in module airflow.example_dags.example_asset_with_watchers) FileSyntaxError (class in airflow.exceptions) finished (airflow.utils.state.State attribute) finished_dr_states (airflow.utils.state.State attribute) FLASK_APP

G

generate_run_id() (airflow.timetables.assets.AssetOrTimeSchedule method) (airflow.timetables.base.Timetable method) generate_value() (in module airflow.example_dags.example_xcomargs) get_airflow_context_vars() (in module airflow.policies) get_config() (airflow.secrets.local_filesystem.LocalFilesystemBackend method) get_conn_value() (airflow.secrets.environment_variables.EnvironmentVariablesBackend method) get_connection() (airflow.secrets.local_filesystem.LocalFilesystemBackend method) (airflow.secrets.metastore.MetastoreBackend method) get_connection_form_widgets() (airflow.hooks.base.DiscoverableHook static method)

get_connection_parameter_names() (in module airflow.secrets.local_filesystem) get_names() (in module airflow.example_dags.example_params_trigger_ui) get_next_workday() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable method) get_nums() (in module airflow.example_dags.example_dynamic_task_mapping) get_ui_field_behaviour() (airflow.hooks.base.DiscoverableHook static method) get_variable() (airflow.secrets.environment_variables.EnvironmentVariablesBackend method) (airflow.secrets.local_filesystem.LocalFilesystemBackend method) (airflow.secrets.metastore.MetastoreBackend method) get_weight() (airflow.example_dags.plugins.decreasing_priority_weight_strategy.DecreasingPriorityStrategy method)

H

hash() (airflow.triggers.base.BaseEventTrigger static method)

holiday_calendar (in module airflow.example_dags.plugins.workday) hook_name (airflow.hooks.base.DiscoverableHook attribute)

I

IdentityMapper (class in airflow.timetables.simple) incoming (airflow.exceptions.AirflowDagDuplicatedIdException attribute) 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.MultipleCronTriggerTimetable method)

ingest (in module airflow.example_dags.example_branch_labels) IntermediateTIState (class in airflow.utils.state) interval() (airflow.timetables.base.DagRunInfo class method) InvalidStatsNameException

K

k8s (in module airflow.example_dags.example_kubernetes_executor) (in module airflow.example_dags.example_local_kubernetes_executor)

L

latest (airflow.timetables.base.TimeRestriction attribute) latest_only (in module airflow.example_dags.example_latest_only_with_trigger) line_no (airflow.exceptions.FileSyntaxError attribute) listeners (airflow.example_dags.plugins.listener_plugin.MetadataCollectionPlugin attribute) load_configs_dict() (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_xcomargs) (in module airflow.example_dags.plugins.workday) (in module airflow.example_dags.tutorial_taskflow_api_virtualenv) (in module airflow.secrets.local_filesystem) (in module airflow.triggers.base) (in module airflow.triggers.callback) logical_date (airflow.timetables.base.DagRunInfo property)

M

Major release message (airflow.exceptions.FileSyntaxError attribute) MetadataCollectionPlugin (class in airflow.example_dags.plugins.listener_plugin) MetastoreBackend (class in airflow.secrets.metastore) module airflow.config_templates.airflow_local_settings 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_branch_labels airflow.example_dags.example_branch_python_dop_operator_3 airflow.example_dags.example_complex airflow.example_dags.example_custom_weight 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_inlet_event_extra airflow.example_dags.example_kubernetes_executor 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_setup_teardown airflow.example_dags.example_setup_teardown_taskflow airflow.example_dags.example_simplest_dag 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_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.policies airflow.sdk.execution_time.macros airflow.secrets airflow.secrets.base_secrets airflow.secrets.environment_variables airflow.secrets.local_filesystem airflow.secrets.metastore airflow.timetables airflow.timetables.assets airflow.timetables.base airflow.timetables.datasets airflow.timetables.events airflow.timetables.interval airflow.timetables.simple airflow.timetables.trigger airflow.triggers airflow.triggers.base airflow.triggers.callback airflow.triggers.testing airflow.utils.state

msg (airflow.exceptions.AirflowFileParseException attribute) MultipleCronTriggerTimetable (class in airflow.timetables.trigger) 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) next_dagrun_info() (airflow.example_dags.plugins.workday.AfterWorkdayTimetable 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.MultipleCronTriggerTimetable method)

next_kwargs (airflow.triggers.base.StartTriggerArgs attribute) next_method (airflow.triggers.base.StartTriggerArgs attribute) NONE (airflow.utils.state.State attribute) NotMapped NullTimetable (class in airflow.timetables.simple)

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_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() (in module airflow.example_dags.example_dynamic_task_mapping)

P

parse_errors (airflow.exceptions.AirflowFileParseException attribute) partition_mapper (airflow.timetables.simple.PartitionedAssetTimetable attribute) PartitionedAssetTimetable (class in airflow.timetables.simple) PartitionMapper (class in airflow.timetables.simple) Patch releases payload (airflow.triggers.base.TriggerEvent attribute) PAYLOAD_BODY_KEY (in module airflow.triggers.callback) PAYLOAD_STATUS_KEY (in module airflow.triggers.callback) periodic (airflow.timetables.assets.AssetOrTimeSchedule attribute) (airflow.timetables.base.Timetable attribute) pod_mutation_hook() (in module airflow.policies) PodMutationHookException PodReconciliationError

PoolNotFound 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_strategies (airflow.example_dags.plugins.decreasing_priority_weight_strategy.DecreasingPriorityWeightStrategyPlugin attribute) 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) push() (in module airflow.example_dags.example_xcom) push_by_returning() (in module airflow.example_dags.example_xcom) PYTHONPATH, [1], [2], [3], [4], [5], [6], [7], [8]

Q

QUEUED (airflow.utils.state.DagRunState attribute) (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute)

R

random() (in module airflow.sdk.execution_time.macros) read_asset_event() (in module airflow.example_dags.example_inlet_event_extra) REMOVED (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute) RemovedInAirflow4Warning repr() (airflow.triggers.base.BaseTrigger static method) RESTARTING (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) restrict_to_events (airflow.timetables.events.EventsTimetable attribute) root_setup (in module airflow.example_dags.example_setup_teardown)

run() (airflow.triggers.base.BaseTrigger method) (airflow.triggers.callback.CallbackTrigger method) (airflow.triggers.testing.FailureTrigger method) (airflow.triggers.testing.SuccessTrigger method) run_after (airflow.timetables.base.DagRunInfo 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_func() (in module airflow.example_dags.example_trigger_target_dag) RUNNING (airflow.utils.state.DagRunState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute)

S

SCHEDULED (airflow.utils.state.IntermediateTIState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) SerializationError serialize() (airflow.exceptions.DagRunAlreadyExists 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.simple.PartitionedAssetTimetable method) (airflow.timetables.simple.PartitionMapper method) (airflow.timetables.trigger.CronTriggerTimetable method) (airflow.timetables.trigger.DeltaTriggerTimetable method) (airflow.timetables.trigger.MultipleCronTriggerTimetable method) (airflow.triggers.base.BaseTrigger method) (airflow.triggers.callback.CallbackTrigger method) (airflow.triggers.testing.FailureTrigger method) (airflow.triggers.testing.SuccessTrigger method) should_run() (in module airflow.example_dags.example_branch_python_dop_operator_3) show_params() (in module airflow.example_dags.example_params_ui_tutorial) SKIPPED (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute)

start (airflow.timetables.base.DataInterval attribute) (in module airflow.example_dags.example_custom_weight) (in module airflow.example_dags.example_task_group) 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) StartTriggerArgs (class in airflow.triggers.base) State (class in airflow.utils.state) state_color (airflow.utils.state.State attribute) status_code (airflow.exceptions.AirflowBadRequest attribute) SUCCESS (airflow.utils.state.DagRunState attribute) (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute) 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.assets.AssetOrTimeSchedule property) (airflow.timetables.base.Timetable property) (airflow.timetables.events.EventsTimetable property) (airflow.timetables.simple.ContinuousTimetable property) (airflow.timetables.simple.NullTimetable property) (airflow.timetables.simple.OnceTimetable property) (airflow.timetables.simple.PartitionedAssetTimetable property) (airflow.timetables.trigger.MultipleCronTriggerTimetable property)

T

t1 (in module airflow.example_dags.tutorial) task_1() (in module airflow.example_dags.example_task_group_decorator) task_2() (in module airflow.example_dags.example_task_group_decorator) task_3() (in module airflow.example_dags.example_task_group_decorator) task_end() (in module airflow.example_dags.example_task_group_decorator) task_group_function() (in module airflow.example_dags.example_task_group_decorator) task_instance (airflow.triggers.base.BaseTrigger attribute) task_instance_mutation_hook() (in module airflow.policies) task_instance_state (airflow.triggers.base.TaskFailedEvent attribute) (airflow.triggers.base.TaskSkippedEvent attribute) (airflow.triggers.base.TaskSuccessEvent 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) TaskFailedEvent (class in airflow.triggers.base) TaskInstanceNotFound TaskInstanceState (class in airflow.utils.state) TaskSkippedEvent (class in airflow.triggers.base) TaskSuccessEvent (class in airflow.triggers.base) template_fields (airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.SumItOperator attribute) TerminalTIState (class in airflow.utils.state)

test_task() (in module airflow.example_dags.example_asset_with_watchers) timeout (airflow.triggers.base.StartTriggerArgs attribute) TimeRestriction (class in airflow.timetables.base) timetable (airflow.timetables.assets.AssetOrTimeSchedule attribute) Timetable (class in airflow.timetables.base) timetables (airflow.example_dags.plugins.workday.WorkdayTimetablePlugin attribute) to_downstream() (airflow.timetables.simple.IdentityMapper method) (airflow.timetables.simple.PartitionMapper method) to_upstream() (airflow.timetables.simple.IdentityMapper method) (airflow.timetables.simple.PartitionMapper method) trigger (in module airflow.example_dags.example_asset_with_watchers) trigger_cls (airflow.triggers.base.StartTriggerArgs attribute) trigger_event_discriminator() (in module airflow.triggers.base) trigger_id (airflow.triggers.base.BaseTrigger attribute) trigger_kwargs (airflow.triggers.base.StartTriggerArgs attribute) TriggerEvent (class in airflow.triggers.base) tutorial_dag (in module airflow.example_dags.tutorial_taskflow_api_virtualenv) 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) unfinished (airflow.utils.state.State attribute) unfinished_dr_states (airflow.utils.state.State attribute) UnknownExecutorException 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) UPSTREAM_FAILED (airflow.utils.state.State attribute) (airflow.utils.state.TaskInstanceState attribute) (airflow.utils.state.TerminalTIState attribute)

V

validate() (airflow.timetables.assets.AssetOrTimeSchedule method) (airflow.timetables.base.Timetable method) value (airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.AddOneOperator attribute) value_1 (in module airflow.example_dags.example_xcom)

value_2 (in module airflow.example_dags.example_xcom) values (airflow.example_dags.example_dynamic_task_mapping_with_no_taskflow_operators.SumItOperator attribute) VAR_ENV_PREFIX (in module airflow.secrets.environment_variables) VariableNotUnique variables_file (airflow.secrets.local_filesystem.LocalFilesystemBackend attribute)

W

wait (in module airflow.example_dags.example_time_delta_sensor_async) 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)

PreviousNext

Was this entry helpful?