Index

A

airflow_pydantic.core.base module airflow_pydantic.core.dag module airflow_pydantic.core.task module airflow_pydantic.extras.balancer.host module airflow_pydantic.extras.balancer.port module airflow_pydantic.extras.balancer.query module airflow_pydantic.extras.common.airflow_functions module airflow_pydantic.extras.common.clean module airflow_pydantic.extras.common.operators module airflow_pydantic.operators.bash module airflow_pydantic.operators.datetime module airflow_pydantic.operators.email module airflow_pydantic.operators.empty module airflow_pydantic.operators.external_task module airflow_pydantic.operators.hitl module airflow_pydantic.operators.latest_only module airflow_pydantic.operators.python module airflow_pydantic.operators.smooth module airflow_pydantic.operators.ssh module airflow_pydantic.operators.trigger module airflow_pydantic.operators.weekday module airflow_pydantic.sensors.base module airflow_pydantic.sensors.bash module airflow_pydantic.sensors.datetime module

airflow_pydantic.sensors.external_task module airflow_pydantic.sensors.filesystem module airflow_pydantic.sensors.python module airflow_pydantic.sensors.time module airflow_pydantic.sensors.timedelta module airflow_pydantic.sensors.weekday module airflow_pydantic.utils.bash module airflow_pydantic.utils.common module airflow_pydantic.utils.env module airflow_pydantic.utils.host module airflow_pydantic.utils.param module airflow_pydantic.utils.path module airflow_pydantic.utils.pool module airflow_pydantic.utils.relativedelta module airflow_pydantic.utils.schedule module airflow_pydantic.utils.ssh_hook module airflow_pydantic.utils.timetables module airflow_pydantic.utils.variable module ALL_DONE (airflow_pydantic.utils.common.TriggerRule attribute) ALL_DONE_MIN_ONE_SUCCESS (airflow_pydantic.utils.common.TriggerRule attribute) ALL_DONE_SETUP_SUCCESS (airflow_pydantic.utils.common.TriggerRule attribute) ALL_FAILED (airflow_pydantic.utils.common.TriggerRule attribute) ALL_SKIPPED (airflow_pydantic.utils.common.TriggerRule attribute) ALL_SUCCESS (airflow_pydantic.utils.common.TriggerRule attribute) all_triggers() (airflow_pydantic.utils.common.TriggerRule class method) allowed_states (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) ALWAYS (airflow_pydantic.utils.common.TriggerRule attribute) append_env (airflow_pydantic.operators.bash.BashTaskArgs attribute) ApprovalOperator (in module airflow_pydantic.operators.hitl) ApprovalOperatorArgs (in module airflow_pydantic.operators.hitl)

B

balancer (airflow_pydantic.extras.balancer.query.BalancerHostQueryConfiguration attribute) (airflow_pydantic.extras.balancer.query.BalancerPortQueryConfiguration attribute) banner_timeout (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) bash_command (airflow_pydantic.operators.bash.BashTaskArgs attribute) (airflow_pydantic.sensors.bash.BashSensorArgs attribute) BashOperator (in module airflow_pydantic.operators.bash) BashOperatorArgs (in module airflow_pydantic.operators.bash) bcc (airflow_pydantic.operators.email.EmailTaskArgs attribute) body (airflow_pydantic.operators.hitl.HITLTaskArgs attribute)

BranchDateTimeOperator (in module airflow_pydantic.operators.datetime) BranchDateTimeOperatorArgs (in module airflow_pydantic.operators.datetime) BranchDayOfWeekOperator (in module airflow_pydantic.operators.weekday) BranchDayOfWeekOperatorArgs (in module airflow_pydantic.operators.weekday) BranchExternalPythonOperator (in module airflow_pydantic.operators.python) BranchExternalPythonOperatorArgs (in module airflow_pydantic.operators.python) BranchPythonOperator (in module airflow_pydantic.operators.python) BranchPythonOperatorArgs (in module airflow_pydantic.operators.python) BranchPythonVirtualenvOperator (in module airflow_pydantic.operators.python) BranchPythonVirtualenvOperatorArgs (in module airflow_pydantic.operators.python)

C

catchup (airflow_pydantic.core.dag.DagArgs attribute) cc (airflow_pydantic.operators.email.EmailTaskArgs attribute) check_existence (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) clean_dag_runs() (in module airflow_pydantic.extras.common.airflow_functions) clean_dags() (in module airflow_pydantic.extras.common.airflow_functions) cmd_timeout (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) command (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) commands (airflow_pydantic.utils.bash.BashCommands attribute) conf (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute)

conn_id (airflow_pydantic.operators.email.EmailTaskArgs attribute) conn_timeout (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) cron (airflow_pydantic.utils.timetables.CronDataIntervalTimetable attribute) (airflow_pydantic.utils.timetables.CronTriggerTimetable attribute) crons (airflow_pydantic.utils.timetables.MultipleCronTriggerTimetable attribute) custom (airflow_pydantic.extras.balancer.query.BalancerHostQueryConfiguration attribute) (airflow_pydantic.extras.balancer.query.BalancerPortQueryConfiguration attribute) custom_headers (airflow_pydantic.operators.email.EmailTaskArgs attribute) cwd (airflow_pydantic.operators.bash.BashTaskArgs attribute) (airflow_pydantic.utils.bash.BashCommands attribute)

D

dag_display_name (airflow_pydantic.core.dag.DagArgs attribute) dag_id (airflow_pydantic.core.dag.Dag attribute) DagClean (class in airflow_pydantic.extras.common.clean) DagCleanOperator (in module airflow_pydantic.extras.common.clean) DagCleanOperatorArgs (in module airflow_pydantic.extras.common.clean) DagModel (in module airflow_pydantic.core.dag) DagRunClean (class in airflow_pydantic.extras.common.clean) days_to_keep (airflow_pydantic.extras.common.clean.DagCleanTaskArgs attribute) default_args (airflow_pydantic.core.dag.DagArgs attribute) default_view (airflow_pydantic.core.dag.DagArgs attribute) defaults (airflow_pydantic.operators.hitl.HITLTaskArgs attribute) deferrable (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) (airflow_pydantic.sensors.filesystem.FileSensorArgs attribute) (airflow_pydantic.sensors.time.TimeSensorArgs attribute) (airflow_pydantic.sensors.timedelta.TimeDeltaSensorArgs attribute) (airflow_pydantic.sensors.timedelta.WaitSensorArgs attribute) delete_failed (airflow_pydantic.extras.common.clean.DagCleanTaskArgs attribute)

delete_successful (airflow_pydantic.extras.common.clean.DagCleanTaskArgs attribute) delta (airflow_pydantic.sensors.timedelta.TimeDeltaSensorArgs attribute) (airflow_pydantic.utils.timetables.DeltaDataIntervalTimetable attribute) (airflow_pydantic.utils.timetables.DeltaTriggerTimetable attribute) dependencies (airflow_pydantic.core.task.Task attribute) depends_on_past (airflow_pydantic.core.task.TaskArgs attribute) description (airflow_pydantic.core.dag.DagArgs attribute) (airflow_pydantic.utils.param.ParamType attribute) (airflow_pydantic.utils.pool.Pool attribute) (airflow_pydantic.utils.timetables.EventsTimetable attribute) (airflow_pydantic.utils.variable.Variable attribute) deserialize_json (airflow_pydantic.utils.variable.Variable attribute) do_xcom_push (airflow_pydantic.core.task.TaskArgs attribute) doc (airflow_pydantic.core.task.TaskArgs attribute) doc_json (airflow_pydantic.core.task.TaskArgs attribute) doc_md (airflow_pydantic.core.dag.DagArgs attribute) (airflow_pydantic.core.task.TaskArgs attribute) doc_rst (airflow_pydantic.core.task.TaskArgs attribute) doc_yaml (airflow_pydantic.core.task.TaskArgs attribute)

E

email (airflow_pydantic.core.task.TaskArgs attribute) email_on_failure (airflow_pydantic.core.task.TaskArgs attribute) email_on_retry (airflow_pydantic.core.task.TaskArgs attribute) EmailOperator (in module airflow_pydantic.operators.email) EmailOperatorArgs (in module airflow_pydantic.operators.email) EmptyOperator (in module airflow_pydantic.operators.empty) EmptyOperatorArgs (in module airflow_pydantic.operators.empty) enabled (airflow_pydantic.core.dag.DagArgs attribute) end_date (airflow_pydantic.core.dag.DagArgs attribute) (airflow_pydantic.core.task.TaskArgs attribute) end_from_trigger (airflow_pydantic.sensors.datetime.DateTimeSensorAsyncArgs attribute) env (airflow_pydantic.operators.bash.BashTaskArgs attribute) (airflow_pydantic.sensors.bash.BashSensorArgs attribute) (airflow_pydantic.utils.bash.BashCommands attribute) env_vars (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute)

environment (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) escape (airflow_pydantic.utils.bash.BashCommands attribute) event_dates (airflow_pydantic.utils.timetables.EventsTimetable attribute) execute() (airflow_pydantic.extras.balancer.query.BalancerHostQueryConfiguration method) (airflow_pydantic.extras.balancer.query.BalancerPortQueryConfiguration method) execution_date_fn (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) execution_delta (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) execution_timeout (airflow_pydantic.core.task.TaskArgs attribute) expect_airflow (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) exponential_backoff (airflow_pydantic.sensors.base.BaseSensorArgs attribute) external_dag_id (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) external_task_group_id (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) external_task_id (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) external_task_ids (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) ExternalPythonOperator (in module airflow_pydantic.operators.python) ExternalPythonOperatorArgs (in module airflow_pydantic.operators.python)

F

fail() (in module airflow_pydantic.extras.common.airflow_functions) failed_states (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) FailOperator (in module airflow_pydantic.extras.common.operators) FailOperatorArgs (in module airflow_pydantic.extras.common.operators) filepath (airflow_pydantic.sensors.filesystem.FileSensorArgs attribute)

files (airflow_pydantic.operators.email.EmailTaskArgs attribute) FixedTimezone (in module airflow_pydantic.utils.timetables) follow_task_ids_if_false (airflow_pydantic.operators.datetime.BranchDateTimeTaskArgs attribute) (airflow_pydantic.operators.weekday.BranchDayOfWeekTaskArgs attribute) follow_task_ids_if_true (airflow_pydantic.operators.datetime.BranchDateTimeTaskArgs attribute) (airflow_pydantic.operators.weekday.BranchDayOfWeekTaskArgs attribute) fs_conn_id (airflow_pydantic.sensors.filesystem.FileSensorArgs attribute)

G

get() (airflow_pydantic.utils.variable.Variable method)

get_pty (airflow_pydantic.operators.ssh.SSHTaskArgs attribute)

H

HITLBranchOperator (in module airflow_pydantic.operators.hitl) HITLBranchOperatorArgs (in module airflow_pydantic.operators.hitl) HITLEntryOperator (in module airflow_pydantic.operators.hitl) HITLEntryOperatorArgs (in module airflow_pydantic.operators.hitl) HITLOperator (in module airflow_pydantic.operators.hitl)

HITLOperatorArgs (in module airflow_pydantic.operators.hitl) hook() (airflow_pydantic.extras.balancer.host.Host method) host (airflow_pydantic.extras.balancer.port.Port attribute) host_name (airflow_pydantic.extras.balancer.port.Port attribute) HostQuery (in module airflow_pydantic.extras.balancer.query) html_content (airflow_pydantic.operators.email.EmailTaskArgs attribute)

I

ignore_downstream_trigger_rules (airflow_pydantic.operators.python.ShortCircuitTaskArgs attribute) in_bash() (in module airflow_pydantic.utils.bash) (in module airflow_pydantic.utils.env) in_conda() (in module airflow_pydantic.utils.env) in_virtualenv() (in module airflow_pydantic.utils.env) include_deferred (airflow_pydantic.utils.pool.Pool attribute) index_urls (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) index_urls_from_connection_ids (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) inherit_env (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) instance() (airflow_pydantic.utils.timetables.CronDataIntervalTimetable method) (airflow_pydantic.utils.timetables.CronTriggerTimetable method) (airflow_pydantic.utils.timetables.DeltaDataIntervalTimetable method) (airflow_pydantic.utils.timetables.DeltaTriggerTimetable method) (airflow_pydantic.utils.timetables.EventsTimetable method) (airflow_pydantic.utils.timetables.MultipleCronTriggerTimetable method)

instantiate() (airflow_pydantic.operators.ssh.SSHTask method) interval (airflow_pydantic.utils.timetables.CronTriggerTimetable attribute) (airflow_pydantic.utils.timetables.DeltaTriggerTimetable attribute) (airflow_pydantic.utils.timetables.MultipleCronTriggerTimetable attribute) is_encrypted (airflow_pydantic.utils.variable.Variable attribute) is_paused_upon_creation (airflow_pydantic.core.dag.DagArgs attribute) is_valid() (airflow_pydantic.utils.common.TriggerRule class method)

K

key (airflow_pydantic.utils.variable.Variable attribute) key_file (airflow_pydantic.extras.balancer.host.Host attribute)

kind (airflow_pydantic.extras.balancer.query.BalancerHostQueryConfiguration attribute) (airflow_pydantic.extras.balancer.query.BalancerPortQueryConfiguration attribute)

L

link() (in module airflow_pydantic.utils.path)

logical_date (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) login (airflow_pydantic.utils.bash.BashCommands attribute)

M

mark_failed_as_successful (airflow_pydantic.extras.common.clean.DagCleanTaskArgs attribute) max_active_runs (airflow_pydantic.core.dag.DagArgs attribute) max_active_tasks (airflow_pydantic.core.dag.DagArgs attribute) max_active_tis_per_dag (airflow_pydantic.core.task.TaskArgs attribute) max_active_tis_per_dagrun (airflow_pydantic.core.task.TaskArgs attribute) max_dagruns (airflow_pydantic.extras.common.clean.DagCleanTaskArgs attribute) max_retry_delay (airflow_pydantic.core.task.TaskArgs attribute) max_wait (airflow_pydantic.sensors.base.BaseSensorArgs attribute) mime_charset (airflow_pydantic.operators.email.EmailTaskArgs attribute) mime_subtype (airflow_pydantic.operators.email.EmailTaskArgs attribute) mode (airflow_pydantic.sensors.base.BaseSensorArgs attribute) model_dump() (airflow_pydantic.core.base.BaseModel method) model_dump_json() (airflow_pydantic.core.base.BaseModel method) module airflow_pydantic.core.base airflow_pydantic.core.dag airflow_pydantic.core.task airflow_pydantic.extras.balancer.host airflow_pydantic.extras.balancer.port airflow_pydantic.extras.balancer.query airflow_pydantic.extras.common.airflow_functions airflow_pydantic.extras.common.clean airflow_pydantic.extras.common.operators airflow_pydantic.operators.bash airflow_pydantic.operators.datetime airflow_pydantic.operators.email airflow_pydantic.operators.empty airflow_pydantic.operators.external_task airflow_pydantic.operators.hitl airflow_pydantic.operators.latest_only airflow_pydantic.operators.python airflow_pydantic.operators.smooth airflow_pydantic.operators.ssh airflow_pydantic.operators.trigger airflow_pydantic.operators.weekday airflow_pydantic.sensors.base airflow_pydantic.sensors.bash airflow_pydantic.sensors.datetime airflow_pydantic.sensors.external_task airflow_pydantic.sensors.filesystem airflow_pydantic.sensors.python airflow_pydantic.sensors.time airflow_pydantic.sensors.timedelta airflow_pydantic.sensors.weekday airflow_pydantic.utils.bash airflow_pydantic.utils.common airflow_pydantic.utils.env airflow_pydantic.utils.host airflow_pydantic.utils.param airflow_pydantic.utils.path airflow_pydantic.utils.pool airflow_pydantic.utils.relativedelta airflow_pydantic.utils.schedule airflow_pydantic.utils.ssh_hook airflow_pydantic.utils.timetables airflow_pydantic.utils.variable

multiple (airflow_pydantic.operators.hitl.HITLTaskArgs attribute) multiple_outputs (airflow_pydantic.core.task.TaskArgs attribute)

N

name (airflow_pydantic.extras.balancer.host.Host attribute) (airflow_pydantic.extras.balancer.port.Port attribute) (airflow_pydantic.extras.balancer.query.BalancerHostQueryConfiguration attribute) (airflow_pydantic.extras.balancer.query.BalancerPortQueryConfiguration attribute)

never_fail (airflow_pydantic.sensors.base.BaseSensorArgs attribute) NONE_FAILED (airflow_pydantic.utils.common.TriggerRule attribute) NONE_FAILED_MIN_ONE_SUCCESS (airflow_pydantic.utils.common.TriggerRule attribute) NONE_SKIPPED (airflow_pydantic.utils.common.TriggerRule attribute)

O

ONE_DONE (airflow_pydantic.utils.common.TriggerRule attribute) ONE_FAILED (airflow_pydantic.utils.common.TriggerRule attribute) ONE_SUCCESS (airflow_pydantic.utils.common.TriggerRule attribute) op_args (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) (airflow_pydantic.sensors.python.PythonSensorArgs attribute) op_kwargs (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) (airflow_pydantic.sensors.python.PythonSensorArgs attribute) operator (airflow_pydantic.core.task.Task attribute) (airflow_pydantic.extras.common.clean.DagCleanTask attribute) (airflow_pydantic.operators.bash.BashTask attribute) (airflow_pydantic.operators.datetime.BranchDateTimeTask attribute) (airflow_pydantic.operators.email.EmailTask attribute) (airflow_pydantic.operators.empty.EmptyTask attribute) (airflow_pydantic.operators.external_task.ExternalTaskMarker attribute) (airflow_pydantic.operators.hitl.ApprovalTask attribute) (airflow_pydantic.operators.hitl.HITLBranchTask attribute) (airflow_pydantic.operators.hitl.HITLEntryTask attribute) (airflow_pydantic.operators.hitl.HITLTask attribute) (airflow_pydantic.operators.python.BranchExternalPythonTask attribute) (airflow_pydantic.operators.python.BranchPythonTask attribute) (airflow_pydantic.operators.python.BranchPythonVirtualenvTask attribute) (airflow_pydantic.operators.python.ExternalPythonTask attribute) (airflow_pydantic.operators.python.PythonTask attribute) (airflow_pydantic.operators.python.PythonVirtualenvTask attribute) (airflow_pydantic.operators.python.ShortCircuitTask attribute) (airflow_pydantic.operators.ssh.SSHTask attribute) (airflow_pydantic.operators.trigger.TriggerDagRunTask attribute) (airflow_pydantic.operators.weekday.BranchDayOfWeekTask attribute) (airflow_pydantic.sensors.bash.BashSensor attribute) (airflow_pydantic.sensors.datetime.DateTimeSensor attribute) (airflow_pydantic.sensors.datetime.DateTimeSensorAsync attribute) (airflow_pydantic.sensors.external_task.ExternalTaskSensor attribute) (airflow_pydantic.sensors.filesystem.FileSensor attribute) (airflow_pydantic.sensors.python.PythonSensor attribute) (airflow_pydantic.sensors.time.TimeSensor attribute) (airflow_pydantic.sensors.timedelta.TimeDeltaSensor attribute) (airflow_pydantic.sensors.timedelta.WaitSensor attribute) (airflow_pydantic.sensors.weekday.DayOfWeekSensor attribute)

options (airflow_pydantic.operators.hitl.HITLTaskArgs attribute) orientation (airflow_pydantic.core.dag.DagArgs attribute) os (airflow_pydantic.extras.balancer.host.Host attribute) (airflow_pydantic.extras.balancer.query.BalancerHostQueryConfiguration attribute) output_encoding (airflow_pydantic.operators.bash.BashTaskArgs attribute) (airflow_pydantic.sensors.bash.BashSensorArgs attribute) output_processor (airflow_pydantic.operators.bash.BashTaskArgs attribute) override() (airflow_pydantic.extras.balancer.host.Host method) owner (airflow_pydantic.core.task.TaskArgs attribute)

P

params (airflow_pydantic.core.dag.DagArgs attribute) (airflow_pydantic.operators.hitl.HITLTaskArgs attribute) ParamType (class in airflow_pydantic.utils.param) pass_() (in module airflow_pydantic.extras.common.airflow_functions) PassOperator (in module airflow_pydantic.extras.common.operators) PassOperatorArgs (in module airflow_pydantic.extras.common.operators) password (airflow_pydantic.extras.balancer.host.Host attribute) ping() (in module airflow_pydantic.utils.host) pip_install_options (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) poke_interval (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) (airflow_pydantic.sensors.base.BaseSensorArgs attribute) poll_interval (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute) pool (airflow_pydantic.core.task.TaskArgs attribute) (airflow_pydantic.extras.balancer.host.Host attribute) (airflow_pydantic.extras.balancer.port.Port property) (airflow_pydantic.utils.pool.Pool attribute)

pool_slots (airflow_pydantic.core.task.TaskArgs attribute) port (airflow_pydantic.extras.balancer.port.Port attribute) PortQuery (in module airflow_pydantic.extras.balancer.query) presorted (airflow_pydantic.utils.timetables.EventsTimetable attribute) python (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) python_callable (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) (airflow_pydantic.sensors.python.PythonSensorArgs attribute) python_version (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) PythonOperator (in module airflow_pydantic.operators.python) PythonOperatorArgs (in module airflow_pydantic.operators.python) PythonVirtualenvOperator (in module airflow_pydantic.operators.python) PythonVirtualenvOperatorArgs (in module airflow_pydantic.operators.python)

Q

queue (airflow_pydantic.core.task.TaskArgs attribute) (airflow_pydantic.extras.balancer.query.BalancerHostQueryConfiguration attribute)

queues (airflow_pydantic.extras.balancer.host.Host attribute) quote (airflow_pydantic.utils.bash.BashCommands attribute)

R

recursive (airflow_pydantic.sensors.filesystem.FileSensorArgs attribute) remote_host (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) render() (airflow_pydantic.operators.ssh.SSHTask method) requirements (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) reset_dag_run (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) restrict_to_events (airflow_pydantic.utils.timetables.EventsTimetable attribute)

retries (airflow_pydantic.core.task.TaskArgs attribute) retry_delay (airflow_pydantic.core.task.TaskArgs attribute) retry_exit_code (airflow_pydantic.sensors.bash.BashSensorArgs attribute) retry_exponential_backoff (airflow_pydantic.core.task.TaskArgs attribute) run_immediately (airflow_pydantic.utils.timetables.CronTriggerTimetable attribute) (airflow_pydantic.utils.timetables.MultipleCronTriggerTimetable attribute)

S

schedule (airflow_pydantic.core.dag.DagArgs attribute) serializer (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) set_downstream() (airflow_pydantic.core.task.Task method) set_upstream() (airflow_pydantic.core.task.Task method) ShortCircuitOperator (in module airflow_pydantic.operators.python) ShortCircuitOperatorArgs (in module airflow_pydantic.operators.python) show_return_value_in_logs (airflow_pydantic.operators.python.PythonTaskArgs attribute) silent_fail (airflow_pydantic.sensors.base.BaseSensorArgs attribute) size (airflow_pydantic.extras.balancer.host.Host attribute) skip() (in module airflow_pydantic.extras.common.airflow_functions) skip_on_exit_code (airflow_pydantic.operators.bash.BashTaskArgs attribute) (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) skip_when_already_exists (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) SkipOperator (in module airflow_pydantic.extras.common.operators) SkipOperatorArgs (in module airflow_pydantic.extras.common.operators) skipped_states (airflow_pydantic.sensors.external_task.ExternalTaskSensorArgs attribute)

slots (airflow_pydantic.utils.pool.Pool attribute) soft_fail (airflow_pydantic.sensors.base.BaseSensorArgs attribute) ssh_conn_id (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) ssh_hook (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) ssh_hook_external (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) ssh_hook_foo (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) ssh_hook_host (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) ssh_hook_hosts (airflow_pydantic.operators.ssh.SSHTaskArgs attribute) SSHOperator (in module airflow_pydantic.operators.ssh) SSHOperatorArgs (in module airflow_pydantic.operators.ssh) start_date (airflow_pydantic.core.dag.DagArgs attribute) (airflow_pydantic.core.task.TaskArgs attribute) start_from_trigger (airflow_pydantic.sensors.datetime.DateTimeSensorAsyncArgs attribute) (airflow_pydantic.sensors.filesystem.FileSensorArgs attribute) string_args (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) subject (airflow_pydantic.operators.email.EmailTaskArgs attribute) (airflow_pydantic.operators.hitl.HITLTaskArgs attribute) system_site_packages (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute)

T

tag (airflow_pydantic.extras.balancer.query.BalancerHostQueryConfiguration attribute) (airflow_pydantic.extras.balancer.query.BalancerPortQueryConfiguration attribute) tags (airflow_pydantic.core.dag.DagArgs attribute) (airflow_pydantic.extras.balancer.host.Host attribute) (airflow_pydantic.extras.balancer.port.Port attribute) target_lower (airflow_pydantic.operators.datetime.BranchDateTimeTaskArgs attribute) (airflow_pydantic.operators.weekday.BranchDayOfWeekTaskArgs attribute) target_time (airflow_pydantic.sensors.datetime.DateTimeSensorArgs attribute) (airflow_pydantic.sensors.datetime.DateTimeSensorAsyncArgs attribute) (airflow_pydantic.sensors.time.TimeSensorArgs attribute) target_upper (airflow_pydantic.operators.datetime.BranchDateTimeTaskArgs attribute) (airflow_pydantic.operators.weekday.BranchDayOfWeekTaskArgs attribute) task_display_name (airflow_pydantic.core.task.TaskArgs attribute) task_id (airflow_pydantic.core.task.Task attribute) TaskModel (in module airflow_pydantic.core.task) tasks (airflow_pydantic.core.dag.Dag attribute) templates_dict (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) (airflow_pydantic.sensors.python.PythonSensorArgs attribute)

templates_exts (airflow_pydantic.operators.python.ExternalPythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonTaskArgs attribute) (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute) time_to_wait (airflow_pydantic.sensors.timedelta.WaitSensorArgs attribute) timeout (airflow_pydantic.sensors.base.BaseSensorArgs attribute) timezone (airflow_pydantic.utils.timetables.CronDataIntervalTimetable attribute) (airflow_pydantic.utils.timetables.CronTriggerTimetable attribute) (airflow_pydantic.utils.timetables.MultipleCronTriggerTimetable attribute) Timezone (in module airflow_pydantic.utils.timetables) title (airflow_pydantic.utils.param.ParamType attribute) to (airflow_pydantic.operators.email.EmailTaskArgs attribute) trigger_dag_id (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) trigger_kwargs (airflow_pydantic.sensors.datetime.DateTimeSensorAsyncArgs attribute) (airflow_pydantic.sensors.filesystem.FileSensorArgs attribute) trigger_rule (airflow_pydantic.core.task.TaskArgs attribute) trigger_run_id (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute) TriggerDagRunOperator (in module airflow_pydantic.operators.trigger) TriggerDagRunOperatorArgs (in module airflow_pydantic.operators.trigger) TriggerRule (class in airflow_pydantic.utils.common) type (airflow_pydantic.utils.param.ParamType attribute)

U

use_task_execution_date (airflow_pydantic.operators.datetime.BranchDateTimeTaskArgs attribute) (airflow_pydantic.operators.weekday.BranchDayOfWeekTaskArgs attribute) use_task_logical_date (airflow_pydantic.operators.datetime.BranchDateTimeTaskArgs attribute) (airflow_pydantic.operators.weekday.BranchDayOfWeekTaskArgs attribute) (airflow_pydantic.sensors.weekday.DayOfWeekSensorArgs attribute)

username (airflow_pydantic.extras.balancer.host.Host attribute)

V

val (airflow_pydantic.utils.variable.Variable attribute)

value (airflow_pydantic.utils.param.ParamType attribute) venv_cache_path (airflow_pydantic.operators.python.PythonVirtualenvTaskArgs attribute)

W

wait_for_completion (airflow_pydantic.operators.trigger.TriggerDagRunTaskArgs attribute)

week_day (airflow_pydantic.sensors.weekday.DayOfWeekSensorArgs attribute)