• Home
• Index

Index

_

__str__() (airflow.providers.standard.operators.trigger_dagrun.DagIsPaused method)

__version__ (in module airflow.providers.standard)

A

airflow.providers.standard module airflow.providers.standard.decorators module airflow.providers.standard.decorators.bash module airflow.providers.standard.decorators.branch_external_python module airflow.providers.standard.decorators.branch_python module airflow.providers.standard.decorators.branch_virtualenv module airflow.providers.standard.decorators.external_python module airflow.providers.standard.decorators.python module airflow.providers.standard.decorators.python_virtualenv module airflow.providers.standard.decorators.sensor module airflow.providers.standard.decorators.short_circuit module airflow.providers.standard.decorators.stub module airflow.providers.standard.example_dags module airflow.providers.standard.example_dags.example_bash_decorator module airflow.providers.standard.example_dags.example_bash_operator module airflow.providers.standard.example_dags.example_branch_datetime_operator module airflow.providers.standard.example_dags.example_branch_day_of_week_operator module airflow.providers.standard.example_dags.example_branch_operator module airflow.providers.standard.example_dags.example_branch_operator_decorator module airflow.providers.standard.example_dags.example_external_task_child_deferrable module airflow.providers.standard.example_dags.example_external_task_marker_dag module airflow.providers.standard.example_dags.example_external_task_parent_deferrable module airflow.providers.standard.example_dags.example_hitl_operator module airflow.providers.standard.example_dags.example_latest_only module airflow.providers.standard.example_dags.example_python_decorator module airflow.providers.standard.example_dags.example_python_operator module airflow.providers.standard.example_dags.example_sensor_decorator module airflow.providers.standard.example_dags.example_sensors module airflow.providers.standard.example_dags.example_short_circuit_decorator module airflow.providers.standard.example_dags.example_short_circuit_operator module airflow.providers.standard.example_dags.example_trigger_controller_dag module airflow.providers.standard.example_dags.sql module airflow.providers.standard.exceptions module airflow.providers.standard.get_provider_info module airflow.providers.standard.hooks module airflow.providers.standard.hooks.filesystem module airflow.providers.standard.hooks.package_index module airflow.providers.standard.hooks.subprocess module

airflow.providers.standard.models module airflow.providers.standard.operators module airflow.providers.standard.operators.bash module airflow.providers.standard.operators.branch module airflow.providers.standard.operators.datetime module airflow.providers.standard.operators.empty module airflow.providers.standard.operators.hitl module airflow.providers.standard.operators.latest_only module airflow.providers.standard.operators.python module airflow.providers.standard.operators.smooth module airflow.providers.standard.operators.trigger_dagrun module airflow.providers.standard.operators.weekday module airflow.providers.standard.sensors module airflow.providers.standard.sensors.bash module airflow.providers.standard.sensors.date_time module airflow.providers.standard.sensors.external_task module airflow.providers.standard.sensors.filesystem module airflow.providers.standard.sensors.python module airflow.providers.standard.sensors.time module airflow.providers.standard.sensors.time_delta module airflow.providers.standard.sensors.weekday module airflow.providers.standard.triggers module airflow.providers.standard.triggers.external_task module airflow.providers.standard.triggers.file module airflow.providers.standard.triggers.hitl module airflow.providers.standard.triggers.temporal module airflow.providers.standard.utils module airflow.providers.standard.utils.python_virtualenv module airflow.providers.standard.utils.sensor_helper module airflow.providers.standard.utils.skipmixin module airflow.providers.standard.utils.weekday module airflow.providers.standard.version_compat module AIRFLOW_V_3_0_PLUS (in module airflow.providers.standard.version_compat) AIRFLOW_V_3_1_PLUS (in module airflow.providers.standard.version_compat) AIRFLOW_V_3_2_PLUS (in module airflow.providers.standard.version_compat) AirflowExternalTaskSensorException allowed_states (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) append_env (airflow.providers.standard.operators.bash.BashOperator attribute) ApprovalOperator (class in airflow.providers.standard.operators.hitl) APPROVE (airflow.providers.standard.operators.hitl.ApprovalOperator attribute) assigned_users (airflow.providers.standard.operators.hitl.HITLOperator attribute)

B

BaseBranchOperator (class in airflow.providers.standard.operators.branch) basepath (airflow.providers.standard.hooks.filesystem.FSHook attribute) bash_command (airflow.providers.standard.operators.bash.BashOperator attribute) (airflow.providers.standard.sensors.bash.BashSensor attribute) bash_task() (in module airflow.providers.standard.decorators.bash) BashOperator (class in airflow.providers.standard.operators.bash) BashSensor (class in airflow.providers.standard.sensors.bash) BLUE (airflow.providers.standard.operators.python.PythonOperator attribute) body (airflow.providers.standard.operators.hitl.HITLOperator attribute)

branch_external_python_task() (in module airflow.providers.standard.decorators.branch_external_python) branch_task() (in module airflow.providers.standard.decorators.branch_python) branch_virtualenv_task() (in module airflow.providers.standard.decorators.branch_virtualenv) BranchDateTimeOperator (class in airflow.providers.standard.operators.datetime) BranchDayOfWeekOperator (class in airflow.providers.standard.operators.weekday) BranchExternalPythonOperator (class in airflow.providers.standard.operators.python) BranchMixIn (class in airflow.providers.standard.operators.branch) BranchPythonOperator (class in airflow.providers.standard.operators.python) BranchPythonVirtualenvOperator (class in airflow.providers.standard.operators.python)

C

check_existence (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) child_task1 (in module airflow.providers.standard.example_dags.example_external_task_marker_dag) choose_branch() (airflow.providers.standard.operators.branch.BaseBranchOperator method) (airflow.providers.standard.operators.datetime.BranchDateTimeOperator method) (airflow.providers.standard.operators.latest_only.LatestOnlyOperator method) (airflow.providers.standard.operators.python.BranchExternalPythonOperator method) (airflow.providers.standard.operators.python.BranchPythonOperator method) (airflow.providers.standard.operators.python.BranchPythonVirtualenvOperator method) (airflow.providers.standard.operators.weekday.BranchDayOfWeekOperator method) chosen_options (airflow.providers.standard.triggers.hitl.HITLTriggerEventSuccessPayload attribute) cond1 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) cond2 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator)

cond3 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) cond_true (in module airflow.providers.standard.example_dags.example_short_circuit_operator) conf (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) conn (airflow.providers.standard.hooks.filesystem.FSHook attribute) (airflow.providers.standard.hooks.package_index.PackageIndexHook attribute) conn_name_attr (airflow.providers.standard.hooks.filesystem.FSHook attribute) (airflow.providers.standard.hooks.package_index.PackageIndexHook attribute) conn_type (airflow.providers.standard.hooks.filesystem.FSHook attribute) (airflow.providers.standard.hooks.package_index.PackageIndexHook attribute) convert() (airflow.providers.standard.utils.weekday.WeekDay class method) count_dags() (airflow.providers.standard.triggers.external_task.DagStateTrigger method) custom_operator_name (airflow.providers.standard.decorators.sensor.DecoratedSensorOperator attribute) cwd (airflow.providers.standard.operators.bash.BashOperator attribute)

D

dag1 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) dag2 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) dag3 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) dag_id (airflow.providers.standard.operators.trigger_dagrun.DagIsPaused attribute) (airflow.providers.standard.triggers.external_task.DagStateTrigger attribute) DagIsPaused DagStateTrigger (class in airflow.providers.standard.triggers.external_task) DateTimeSensor (class in airflow.providers.standard.sensors.date_time) DateTimeSensorAsync (class in airflow.providers.standard.sensors.date_time) DateTimeTrigger (class in airflow.providers.standard.triggers.temporal) DayOfWeekSensor (class in airflow.providers.standard.sensors.weekday) DecoratedSensorOperator (class in airflow.providers.standard.decorators.sensor)

default_conn_name (airflow.providers.standard.hooks.filesystem.FSHook attribute) (airflow.providers.standard.hooks.package_index.PackageIndexHook attribute) defaults (airflow.providers.standard.operators.hitl.HITLOperator attribute) (airflow.providers.standard.triggers.hitl.HITLTrigger attribute) deferrable (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.sensors.filesystem.FileSensor attribute) (airflow.providers.standard.sensors.time.TimeSensor attribute) (airflow.providers.standard.sensors.time_delta.TimeDeltaSensor attribute) (airflow.providers.standard.sensors.time_delta.WaitSensor attribute) delta (airflow.providers.standard.sensors.time_delta.TimeDeltaSensor attribute) determine_kwargs() (airflow.providers.standard.operators.python.PythonOperator method) do_branch() (airflow.providers.standard.operators.branch.BranchMixIn method) DuplicateStateError

E

empty_task_1 (in module airflow.providers.standard.example_dags.example_branch_day_of_week_operator) empty_task_11 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) empty_task_12 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) empty_task_13 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) empty_task_21 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) empty_task_22 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) empty_task_23 (in module airflow.providers.standard.example_dags.example_branch_datetime_operator) EmptyOperator (class in airflow.providers.standard.operators.empty) end_from_trigger (airflow.providers.standard.sensors.date_time.DateTimeSensorAsync attribute) (airflow.providers.standard.sensors.time.TimeSensor attribute) (airflow.providers.standard.sensors.time_delta.TimeDeltaSensor attribute) (airflow.providers.standard.triggers.temporal.DateTimeTrigger attribute) env (airflow.providers.standard.operators.bash.BashOperator attribute) (airflow.providers.standard.sensors.bash.BashSensor attribute) error (airflow.providers.standard.triggers.hitl.HITLTriggerEventFailurePayload attribute) error_type (airflow.providers.standard.triggers.hitl.HITLTriggerEventFailurePayload attribute) example_bash_decorator() (in module airflow.providers.standard.example_dags.example_bash_decorator) example_dag (in module airflow.providers.standard.example_dags.example_python_decorator) (in module airflow.providers.standard.example_dags.example_short_circuit_decorator) example_python_decorator() (in module airflow.providers.standard.example_dags.example_python_decorator) example_sensor_decorator() (in module airflow.providers.standard.example_dags.example_sensor_decorator) example_short_circuit_decorator() (in module airflow.providers.standard.example_dags.example_short_circuit_decorator) execute() (airflow.providers.standard.operators.bash.BashOperator method) (airflow.providers.standard.operators.branch.BaseBranchOperator method) (airflow.providers.standard.operators.empty.EmptyOperator method) (airflow.providers.standard.operators.hitl.HITLOperator method) (airflow.providers.standard.operators.python.PythonOperator method) (airflow.providers.standard.operators.python.ShortCircuitOperator method) (airflow.providers.standard.operators.smooth.SmoothOperator method) (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator method) (airflow.providers.standard.sensors.date_time.DateTimeSensorAsync method) (airflow.providers.standard.sensors.external_task.ExternalTaskSensor method) (airflow.providers.standard.sensors.filesystem.FileSensor method) (airflow.providers.standard.sensors.time.TimeSensor method) (airflow.providers.standard.sensors.time_delta.TimeDeltaSensor method) (airflow.providers.standard.sensors.time_delta.WaitSensor method) execute_callable() (airflow.providers.standard.operators.python.ExternalPythonOperator method) (airflow.providers.standard.operators.python.PythonOperator method) (airflow.providers.standard.operators.python.PythonVirtualenvOperator method)

execute_complete() (airflow.providers.standard.operators.hitl.ApprovalOperator method) (airflow.providers.standard.operators.hitl.HITLBranchOperator method) (airflow.providers.standard.operators.hitl.HITLOperator method) (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator method) (airflow.providers.standard.sensors.date_time.DateTimeSensorAsync method) (airflow.providers.standard.sensors.external_task.ExternalTaskSensor method) (airflow.providers.standard.sensors.filesystem.FileSensor method) (airflow.providers.standard.sensors.time.TimeSensor method) (airflow.providers.standard.sensors.time_delta.TimeDeltaSensor method) execution_date_fn (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) execution_dates (airflow.providers.standard.triggers.external_task.DagStateTrigger attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) execution_delta (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) exit_code (airflow.providers.standard.hooks.subprocess.SubprocessResult attribute) expect_pendulum (airflow.providers.standard.operators.python.ExternalPythonOperator attribute) external_dag_id (airflow.providers.standard.sensors.external_task.ExternalTaskMarker attribute) (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) external_python_task() (in module airflow.providers.standard.decorators.external_python) external_task_group_id (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) external_task_id (airflow.providers.standard.sensors.external_task.ExternalTaskMarker attribute) (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) external_task_ids (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) ExternalDagDeletedError ExternalDagFailedError ExternalDagLink (class in airflow.providers.standard.sensors.external_task) ExternalDagNotFoundError ExternalPythonOperator (class in airflow.providers.standard.operators.python) ExternalTaskFailedError ExternalTaskGroupFailedError ExternalTaskGroupNotFoundError ExternalTaskMarker (class in airflow.providers.standard.sensors.external_task) ExternalTaskNotFoundError ExternalTaskSensor (class in airflow.providers.standard.sensors.external_task)

F

fail_on_reject (airflow.providers.standard.operators.hitl.ApprovalOperator attribute) fail_when_dag_is_paused (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) failed_states (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) failure_callable() (in module airflow.providers.standard.example_dags.example_sensors) FileDeleteTrigger (class in airflow.providers.standard.triggers.file) filepath (airflow.providers.standard.sensors.filesystem.FileSensor attribute) (airflow.providers.standard.triggers.file.FileDeleteTrigger attribute) (airflow.providers.standard.triggers.file.FileTrigger attribute)

FileSensor (class in airflow.providers.standard.sensors.filesystem) FileTrigger (class in airflow.providers.standard.triggers.file) FIXED_ARGS (airflow.providers.standard.operators.hitl.ApprovalOperator attribute) follow_task_ids_if_false (airflow.providers.standard.operators.datetime.BranchDateTimeOperator attribute) (airflow.providers.standard.operators.weekday.BranchDayOfWeekOperator attribute) follow_task_ids_if_true (airflow.providers.standard.operators.datetime.BranchDateTimeOperator attribute) (airflow.providers.standard.operators.weekday.BranchDayOfWeekOperator attribute) FRIDAY (airflow.providers.standard.utils.weekday.WeekDay attribute) fs_conn_id (airflow.providers.standard.sensors.filesystem.FileSensor attribute) FSHook (class in airflow.providers.standard.hooks.filesystem)

G

generate_link_to_ui() (airflow.providers.standard.operators.hitl.HITLOperator method) generate_link_to_ui_from_context() (airflow.providers.standard.operators.hitl.HITLOperator static method) get_conn() (airflow.providers.standard.hooks.filesystem.FSHook method) (airflow.providers.standard.hooks.package_index.PackageIndexHook method) get_connection_form_widgets() (airflow.providers.standard.hooks.filesystem.FSHook class method) get_connection_url() (airflow.providers.standard.hooks.package_index.PackageIndexHook method) get_count() (airflow.providers.standard.sensors.external_task.ExternalTaskSensor method) get_current_context() (in module airflow.providers.standard.operators.python) get_env() (airflow.providers.standard.operators.bash.BashOperator method)

get_external_task_group_task_ids() (airflow.providers.standard.sensors.external_task.ExternalTaskSensor method) get_link() (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunLink method) (airflow.providers.standard.sensors.external_task.ExternalDagLink method) get_path() (airflow.providers.standard.hooks.filesystem.FSHook method) get_provider_info() (in module airflow.providers.standard.get_provider_info) get_serialized_fields() (airflow.providers.standard.sensors.external_task.ExternalTaskMarker class method) get_ui_field_behaviour() (airflow.providers.standard.hooks.filesystem.FSHook class method) (airflow.providers.standard.hooks.package_index.PackageIndexHook static method) get_weekday_number() (airflow.providers.standard.utils.weekday.WeekDay class method)

H

hitl_failure_callback (in module airflow.providers.standard.example_dags.example_hitl_operator) hitl_request_callback (in module airflow.providers.standard.example_dags.example_hitl_operator) hitl_success_callback (in module airflow.providers.standard.example_dags.example_hitl_operator) HITLBranchOperator (class in airflow.providers.standard.operators.hitl) HITLEntryOperator (class in airflow.providers.standard.operators.hitl) HITLOperator (class in airflow.providers.standard.operators.hitl) HITLRejectException

HITLTimeoutError HITLTrigger (class in airflow.providers.standard.triggers.hitl) HITLTriggerEventError HITLTriggerEventFailurePayload (class in airflow.providers.standard.triggers.hitl) HITLTriggerEventSuccessPayload (class in airflow.providers.standard.triggers.hitl) hook_name (airflow.providers.standard.hooks.filesystem.FSHook attribute) (airflow.providers.standard.hooks.package_index.PackageIndexHook attribute)

I

ignore_downstream_trigger_rules (airflow.providers.standard.operators.hitl.ApprovalOperator attribute) (airflow.providers.standard.operators.python.ShortCircuitOperator attribute) inherits_from_empty_operator (airflow.providers.standard.operators.empty.EmptyOperator attribute)

inherits_from_skipmixin (airflow.providers.standard.operators.branch.BaseBranchOperator attribute) (airflow.providers.standard.operators.hitl.ApprovalOperator attribute) (airflow.providers.standard.operators.hitl.HITLBranchOperator attribute) (airflow.providers.standard.operators.python.ShortCircuitOperator attribute)

L

latest_only (in module airflow.providers.standard.example_dags.example_latest_only) LatestOnlyOperator (class in airflow.providers.standard.operators.latest_only) LocalLogNotifier (class in airflow.providers.standard.example_dags.example_hitl_operator) log (in module airflow.providers.standard.example_dags.example_python_decorator) (in module airflow.providers.standard.example_dags.example_python_operator) (in module airflow.providers.standard.operators.python)

logical_date (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) logical_dates (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute)

M

message (airflow.providers.standard.example_dags.example_hitl_operator.LocalLogNotifier attribute) module airflow.providers.standard airflow.providers.standard.decorators airflow.providers.standard.decorators.bash airflow.providers.standard.decorators.branch_external_python airflow.providers.standard.decorators.branch_python airflow.providers.standard.decorators.branch_virtualenv airflow.providers.standard.decorators.external_python airflow.providers.standard.decorators.python airflow.providers.standard.decorators.python_virtualenv airflow.providers.standard.decorators.sensor airflow.providers.standard.decorators.short_circuit airflow.providers.standard.decorators.stub airflow.providers.standard.example_dags airflow.providers.standard.example_dags.example_bash_decorator airflow.providers.standard.example_dags.example_bash_operator airflow.providers.standard.example_dags.example_branch_datetime_operator airflow.providers.standard.example_dags.example_branch_day_of_week_operator airflow.providers.standard.example_dags.example_branch_operator airflow.providers.standard.example_dags.example_branch_operator_decorator airflow.providers.standard.example_dags.example_external_task_child_deferrable airflow.providers.standard.example_dags.example_external_task_marker_dag airflow.providers.standard.example_dags.example_external_task_parent_deferrable airflow.providers.standard.example_dags.example_hitl_operator airflow.providers.standard.example_dags.example_latest_only airflow.providers.standard.example_dags.example_python_decorator airflow.providers.standard.example_dags.example_python_operator airflow.providers.standard.example_dags.example_sensor_decorator airflow.providers.standard.example_dags.example_sensors airflow.providers.standard.example_dags.example_short_circuit_decorator airflow.providers.standard.example_dags.example_short_circuit_operator airflow.providers.standard.example_dags.example_trigger_controller_dag airflow.providers.standard.example_dags.sql airflow.providers.standard.exceptions airflow.providers.standard.get_provider_info airflow.providers.standard.hooks airflow.providers.standard.hooks.filesystem airflow.providers.standard.hooks.package_index airflow.providers.standard.hooks.subprocess airflow.providers.standard.models airflow.providers.standard.operators airflow.providers.standard.operators.bash airflow.providers.standard.operators.branch airflow.providers.standard.operators.datetime airflow.providers.standard.operators.empty airflow.providers.standard.operators.hitl airflow.providers.standard.operators.latest_only airflow.providers.standard.operators.python airflow.providers.standard.operators.smooth airflow.providers.standard.operators.trigger_dagrun airflow.providers.standard.operators.weekday airflow.providers.standard.sensors airflow.providers.standard.sensors.bash airflow.providers.standard.sensors.date_time airflow.providers.standard.sensors.external_task airflow.providers.standard.sensors.filesystem airflow.providers.standard.sensors.python airflow.providers.standard.sensors.time airflow.providers.standard.sensors.time_delta airflow.providers.standard.sensors.weekday airflow.providers.standard.triggers airflow.providers.standard.triggers.external_task airflow.providers.standard.triggers.file airflow.providers.standard.triggers.hitl airflow.providers.standard.triggers.temporal airflow.providers.standard.utils airflow.providers.standard.utils.python_virtualenv airflow.providers.standard.utils.sensor_helper airflow.providers.standard.utils.skipmixin airflow.providers.standard.utils.weekday airflow.providers.standard.version_compat

moment (airflow.providers.standard.triggers.temporal.DateTimeTrigger attribute) MONDAY (airflow.providers.standard.utils.weekday.WeekDay attribute) multiple (airflow.providers.standard.operators.hitl.HITLOperator attribute) (airflow.providers.standard.triggers.hitl.HITLTrigger attribute)

N

name (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunLink attribute) (airflow.providers.standard.sensors.external_task.ExternalDagLink attribute) next_kwargs (airflow.providers.standard.sensors.date_time.StartTriggerArgs attribute) (airflow.providers.standard.sensors.filesystem.StartTriggerArgs attribute) (airflow.providers.standard.sensors.time.StartTriggerArgs attribute)

next_method (airflow.providers.standard.sensors.date_time.StartTriggerArgs attribute) (airflow.providers.standard.sensors.filesystem.StartTriggerArgs attribute) (airflow.providers.standard.sensors.time.StartTriggerArgs attribute) notifiers (airflow.providers.standard.operators.hitl.HITLOperator attribute) notify() (airflow.providers.standard.example_dags.example_hitl_operator.LocalLogNotifier method)

O

OK (airflow.providers.standard.operators.hitl.HITLEntryOperator attribute) on_kill() (airflow.providers.standard.operators.bash.BashOperator method) op_args (airflow.providers.standard.operators.python.PythonOperator attribute) (airflow.providers.standard.sensors.python.PythonSensor attribute) op_kwargs (airflow.providers.standard.operators.python.PythonOperator attribute) (airflow.providers.standard.sensors.python.PythonSensor attribute) operator_extra_links (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.providers.standard.sensors.external_task.ExternalTaskMarker attribute) (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute)

options (airflow.providers.standard.operators.hitl.HITLOperator attribute) (airflow.providers.standard.triggers.hitl.HITLTrigger attribute) options_mapping (airflow.providers.standard.operators.hitl.HITLBranchOperator attribute) output (airflow.providers.standard.hooks.subprocess.SubprocessResult attribute) output_encoding (airflow.providers.standard.operators.bash.BashOperator attribute) (airflow.providers.standard.sensors.bash.BashSensor attribute) output_processor (airflow.providers.standard.operators.bash.BashOperator attribute)

P

PackageIndexHook (class in airflow.providers.standard.hooks.package_index) params (airflow.providers.standard.operators.hitl.HITLOperator attribute) (airflow.providers.standard.triggers.hitl.HITLTrigger attribute) params_input (airflow.providers.standard.triggers.hitl.HITLTriggerEventSuccessPayload attribute) parent_task (in module airflow.providers.standard.example_dags.example_external_task_marker_dag) path (airflow.providers.standard.sensors.filesystem.FileSensor property) PATH_TO_PYTHON_BINARY (in module airflow.providers.standard.example_dags.example_branch_operator) (in module airflow.providers.standard.example_dags.example_branch_operator_decorator) (in module airflow.providers.standard.example_dags.example_python_decorator) (in module airflow.providers.standard.example_dags.example_python_operator) pi_conn_id (airflow.providers.standard.hooks.package_index.PackageIndexHook attribute) pip_install_options (airflow.providers.standard.operators.python.PythonVirtualenvOperator attribute) poke() (airflow.providers.standard.sensors.bash.BashSensor method) (airflow.providers.standard.sensors.date_time.DateTimeSensor method) (airflow.providers.standard.sensors.external_task.ExternalTaskSensor method) (airflow.providers.standard.sensors.filesystem.FileSensor method) (airflow.providers.standard.sensors.python.PythonSensor method) (airflow.providers.standard.sensors.time.TimeSensor method) (airflow.providers.standard.sensors.time_delta.TimeDeltaSensor method) (airflow.providers.standard.sensors.weekday.DayOfWeekSensor method)

poke_interval (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) (airflow.providers.standard.triggers.file.FileDeleteTrigger attribute) (airflow.providers.standard.triggers.file.FileTrigger attribute) (airflow.providers.standard.triggers.hitl.HITLTrigger attribute) poll_interval (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.triggers.external_task.DagStateTrigger attribute) prepare_virtualenv() (in module airflow.providers.standard.utils.python_virtualenv) print_context() (in module airflow.providers.standard.example_dags.example_python_operator) process_trigger_event_error() (airflow.providers.standard.operators.hitl.HITLOperator method) python (airflow.providers.standard.operators.python.ExternalPythonOperator attribute) python_callable (airflow.providers.standard.operators.python.PythonOperator attribute) (airflow.providers.standard.sensors.python.PythonSensor attribute) python_task() (in module airflow.providers.standard.decorators.python) python_version (airflow.providers.standard.operators.python.PythonVirtualenvOperator attribute) PythonOperator (class in airflow.providers.standard.operators.python) PythonSensor (class in airflow.providers.standard.sensors.python) PythonVirtualenvOperator (class in airflow.providers.standard.operators.python)

R

recursion_depth (airflow.providers.standard.sensors.external_task.ExternalTaskMarker attribute) recursive (airflow.providers.standard.sensors.filesystem.FileSensor attribute) (airflow.providers.standard.triggers.file.FileTrigger attribute) REJECT (airflow.providers.standard.operators.hitl.ApprovalOperator attribute) reset_dag_run (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) responded_at (airflow.providers.standard.triggers.hitl.HITLTriggerEventSuccessPayload attribute) responded_by_user (airflow.providers.standard.triggers.hitl.HITLTriggerEventSuccessPayload attribute) retry_exit_code (airflow.providers.standard.sensors.bash.BashSensor attribute) run() (airflow.providers.standard.triggers.external_task.DagStateTrigger method) (airflow.providers.standard.triggers.external_task.WorkflowTrigger method) (airflow.providers.standard.triggers.file.FileDeleteTrigger method) (airflow.providers.standard.triggers.file.FileTrigger method) (airflow.providers.standard.triggers.hitl.HITLTrigger method) (airflow.providers.standard.triggers.temporal.DateTimeTrigger method)

run_command() (airflow.providers.standard.hooks.subprocess.SubprocessHook method) run_ids (airflow.providers.standard.triggers.external_task.DagStateTrigger attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) run_this_first (in module airflow.providers.standard.example_dags.example_branch_operator) (in module airflow.providers.standard.example_dags.example_branch_operator_decorator) run_this_last (in module airflow.providers.standard.example_dags.example_bash_operator)

S

SATURDAY (airflow.providers.standard.utils.weekday.WeekDay attribute) send_sigterm() (airflow.providers.standard.hooks.subprocess.SubprocessHook method) sensor_task() (in module airflow.providers.standard.decorators.sensor) serialize() (airflow.providers.standard.triggers.external_task.DagStateTrigger method) (airflow.providers.standard.triggers.external_task.WorkflowTrigger method) (airflow.providers.standard.triggers.file.FileDeleteTrigger method) (airflow.providers.standard.triggers.file.FileTrigger method) (airflow.providers.standard.triggers.hitl.HITLTrigger method) (airflow.providers.standard.triggers.temporal.DateTimeTrigger method) serialized_params (airflow.providers.standard.operators.hitl.HITLOperator property) shallow_copy_attrs (airflow.providers.standard.decorators.sensor.DecoratedSensorOperator attribute) (airflow.providers.standard.operators.python.PythonOperator attribute) short_circuit_task() (in module airflow.providers.standard.decorators.short_circuit) ShortCircuitOperator (class in airflow.providers.standard.operators.python) show_return_value_in_logs (airflow.providers.standard.operators.python.PythonOperator attribute) skip() (airflow.providers.standard.utils.skipmixin.SkipMixin method) skip_all_except() (airflow.providers.standard.utils.skipmixin.SkipMixin method) skip_on_exit_code (airflow.providers.standard.operators.bash.BashOperator attribute) skip_when_already_exists (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) SkipMixin (class in airflow.providers.standard.utils.skipmixin) skipped_states (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute)

SmoothOperator (class in airflow.providers.standard.operators.smooth) soft_fail (airflow.providers.standard.triggers.external_task.WorkflowTrigger attribute) start (in module airflow.providers.standard.example_dags.example_external_task_parent_deferrable) start_date (in module airflow.providers.standard.example_dags.example_external_task_marker_dag) start_from_trigger (airflow.providers.standard.sensors.date_time.DateTimeSensorAsync attribute) (airflow.providers.standard.sensors.filesystem.FileSensor attribute) (airflow.providers.standard.sensors.time.TimeSensor attribute) start_trigger_args (airflow.providers.standard.sensors.date_time.DateTimeSensorAsync attribute) (airflow.providers.standard.sensors.filesystem.FileSensor attribute) (airflow.providers.standard.sensors.time.TimeSensor attribute) StartTriggerArgs (class in airflow.providers.standard.sensors.date_time) (class in airflow.providers.standard.sensors.filesystem) (class in airflow.providers.standard.sensors.time) states (airflow.providers.standard.triggers.external_task.DagStateTrigger attribute) stub() (in module airflow.providers.standard.decorators.stub) sub_process (airflow.providers.standard.hooks.subprocess.SubprocessHook attribute) subject (airflow.providers.standard.operators.hitl.HITLOperator attribute) subprocess_hook (airflow.providers.standard.operators.bash.BashOperator property) SubprocessHook (class in airflow.providers.standard.hooks.subprocess) SubprocessResult (class in airflow.providers.standard.hooks.subprocess) success_callable() (in module airflow.providers.standard.example_dags.example_sensors) SUNDAY (airflow.providers.standard.utils.weekday.WeekDay attribute) system_site_packages (airflow.providers.standard.operators.python.PythonVirtualenvOperator attribute)

T

t0 (in module airflow.providers.standard.example_dags.example_sensors) target_datetime (airflow.providers.standard.sensors.time.TimeSensor attribute) target_lower (airflow.providers.standard.operators.datetime.BranchDateTimeOperator attribute) target_times_as_dates() (in module airflow.providers.standard.operators.datetime) target_upper (airflow.providers.standard.operators.datetime.BranchDateTimeOperator attribute) template_ext (airflow.providers.standard.operators.bash.BashOperator attribute) (airflow.providers.standard.operators.python.PythonVirtualenvOperator attribute) template_fields (airflow.providers.standard.decorators.sensor.DecoratedSensorOperator attribute) (airflow.providers.standard.example_dags.example_hitl_operator.LocalLogNotifier attribute) (airflow.providers.standard.operators.bash.BashOperator attribute) (airflow.providers.standard.operators.hitl.HITLOperator attribute) (airflow.providers.standard.operators.python.ExternalPythonOperator attribute) (airflow.providers.standard.operators.python.PythonOperator attribute) (airflow.providers.standard.operators.python.PythonVirtualenvOperator attribute) (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.providers.standard.sensors.bash.BashSensor attribute) (airflow.providers.standard.sensors.date_time.DateTimeSensor attribute) (airflow.providers.standard.sensors.external_task.ExternalTaskMarker attribute) (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.sensors.filesystem.FileSensor attribute) (airflow.providers.standard.sensors.python.PythonSensor attribute) template_fields_renderers (airflow.providers.standard.decorators.sensor.DecoratedSensorOperator attribute) (airflow.providers.standard.operators.bash.BashOperator attribute) (airflow.providers.standard.operators.python.PythonOperator attribute) (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) templates_dict (airflow.providers.standard.operators.python.PythonOperator attribute) (airflow.providers.standard.sensors.python.PythonSensor attribute)

test_connection() (airflow.providers.standard.hooks.filesystem.FSHook method) (airflow.providers.standard.hooks.package_index.PackageIndexHook method) this_will_skip (in module airflow.providers.standard.example_dags.example_bash_operator) THURSDAY (airflow.providers.standard.utils.weekday.WeekDay attribute) ti_id (airflow.providers.standard.triggers.hitl.HITLTrigger attribute) TimeDeltaSensor (class in airflow.providers.standard.sensors.time_delta) TimeDeltaSensorAsync (class in airflow.providers.standard.sensors.time_delta) TimeDeltaTrigger (class in airflow.providers.standard.triggers.temporal) timedout (airflow.providers.standard.triggers.hitl.HITLTriggerEventSuccessPayload attribute) timeout (airflow.providers.standard.sensors.date_time.StartTriggerArgs attribute) (airflow.providers.standard.sensors.filesystem.StartTriggerArgs attribute) (airflow.providers.standard.sensors.time.StartTriggerArgs attribute) timeout_datetime (airflow.providers.standard.triggers.hitl.HITLTrigger attribute) TimeSensor (class in airflow.providers.standard.sensors.time) TimeSensorAsync (class in airflow.providers.standard.sensors.time) trigger (in module airflow.providers.standard.example_dags.example_trigger_controller_dag) trigger_cls (airflow.providers.standard.sensors.date_time.StartTriggerArgs attribute) (airflow.providers.standard.sensors.filesystem.StartTriggerArgs attribute) (airflow.providers.standard.sensors.time.StartTriggerArgs attribute) trigger_dag_id (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) trigger_kwargs (airflow.providers.standard.sensors.date_time.StartTriggerArgs attribute) (airflow.providers.standard.sensors.filesystem.StartTriggerArgs attribute) (airflow.providers.standard.sensors.time.StartTriggerArgs attribute) trigger_run_id (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) TriggerDagRunLink (class in airflow.providers.standard.operators.trigger_dagrun) TriggerDagRunOperator (class in airflow.providers.standard.operators.trigger_dagrun) TUESDAY (airflow.providers.standard.utils.weekday.WeekDay attribute) tutorial_etl_dag (in module airflow.providers.standard.example_dags.example_sensor_decorator)

U

ui_color (airflow.providers.standard.operators.bash.BashOperator attribute) (airflow.providers.standard.operators.empty.EmptyOperator attribute) (airflow.providers.standard.operators.latest_only.LatestOnlyOperator attribute) (airflow.providers.standard.operators.python.PythonOperator attribute) (airflow.providers.standard.operators.smooth.SmoothOperator attribute) (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) (airflow.providers.standard.sensors.external_task.ExternalTaskMarker attribute) (airflow.providers.standard.sensors.external_task.ExternalTaskSensor attribute) (airflow.providers.standard.sensors.filesystem.FileSensor attribute)

use_task_logical_date (airflow.providers.standard.operators.datetime.BranchDateTimeOperator attribute) (airflow.providers.standard.operators.weekday.BranchDayOfWeekOperator attribute) (airflow.providers.standard.sensors.weekday.DayOfWeekSensor attribute)

V

validate_chosen_options() (airflow.providers.standard.operators.hitl.HITLOperator method) validate_count_dags_af_3() (airflow.providers.standard.triggers.external_task.DagStateTrigger method) validate_defaults() (airflow.providers.standard.operators.hitl.HITLOperator method) validate_options() (airflow.providers.standard.operators.hitl.HITLOperator method) validate_options_mapping() (airflow.providers.standard.operators.hitl.HITLBranchOperator method)

validate_params() (airflow.providers.standard.operators.hitl.HITLOperator method) validate_params_input() (airflow.providers.standard.operators.hitl.HITLOperator method) validate_week_day() (airflow.providers.standard.utils.weekday.WeekDay class method) venv_cache_path (airflow.providers.standard.operators.python.PythonVirtualenvOperator attribute) virtualenv_task() (in module airflow.providers.standard.decorators.python_virtualenv)

W

wait_for_completion (airflow.providers.standard.operators.trigger_dagrun.TriggerDagRunOperator attribute) wait_for_input (in module airflow.providers.standard.example_dags.example_hitl_operator) WaitSensor (class in airflow.providers.standard.sensors.time_delta) WEDNESDAY (airflow.providers.standard.utils.weekday.WeekDay attribute) week_day (airflow.providers.standard.operators.weekday.BranchDayOfWeekOperator attribute) (airflow.providers.standard.sensors.weekday.DayOfWeekSensor attribute)

WeekDay (class in airflow.providers.standard.utils.weekday) WorkflowTrigger (class in airflow.providers.standard.triggers.external_task) working_directory() (in module airflow.providers.standard.hooks.subprocess) write_python_script() (in module airflow.providers.standard.utils.python_virtualenv)

X

XCOM_LOGICAL_DATE_ISO (in module airflow.providers.standard.operators.trigger_dagrun) XCOM_RUN_ID (in module airflow.providers.standard.operators.trigger_dagrun)

XCOM_SKIPMIXIN_FOLLOWED (in module airflow.providers.standard.utils.skipmixin) XCOM_SKIPMIXIN_KEY (in module airflow.providers.standard.utils.skipmixin) XCOM_SKIPMIXIN_SKIPPED (in module airflow.providers.standard.utils.skipmixin)

Y

yt_link (airflow.providers.standard.operators.smooth.SmoothOperator attribute)

PreviousNext

Was this entry helpful?