Index

A

add_task() (airflow.models.DAG method) add_tasks() (airflow.models.DAG method) airflow.macros (module)

airflow.models (module) are_dependencies_met() (airflow.models.TaskInstance method) are_dependents_done() (airflow.models.TaskInstance method)

B

bag_dag() (airflow.models.DagBag method) BaseOperator (class in airflow.models), [1] BashOperator (class in airflow.operators.bash_operator)

BranchPythonOperator (class in airflow.operators.python_operator) bulk_dump() (airflow.hooks.dbapi_hook.DbApiHook method) bulk_load() (airflow.hooks.dbapi_hook.DbApiHook method)

C

check_output() (airflow.contrib.hooks.ssh_hook.SSHHook method) CheckOperator (class in airflow.operators.check_operator) clear() (airflow.models.BaseOperator method), [1] (airflow.models.DAG method) clear_task_instances() (in module airflow.models) clear_xcom_data() (airflow.models.TaskInstance method) cli() (airflow.models.DAG method) close_conn() (airflow.contrib.hooks.ftp_hook.FTPHook method) closest_ds_partition() (in module airflow.macros.hive)

collect_dags() (airflow.models.DagBag method) command() (airflow.models.TaskInstance method) command_as_list() (airflow.models.TaskInstance method) concurrency_reached (airflow.models.DAG attribute) Connection (class in airflow.models) crawl_for_tasks() (airflow.models.DAG method) create_dagrun() (airflow.models.DAG method) create_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) current_state() (airflow.models.TaskInstance method)

D

dag (airflow.models.BaseOperator attribute), [1] DAG (class in airflow.models) DagBag (class in airflow.models) dagbag_report() (airflow.models.DagBag method) DagPickle (class in airflow.models) DagRun (class in airflow.models) DbApiHook (class in airflow.hooks.dbapi_hook) deactivate_stale_dags() (airflow.models.DAG static method) deactivate_unknown_dags() (airflow.models.DAG static method)

delete_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) delete_file() (airflow.contrib.hooks.ftp_hook.FTPHook method) deps (airflow.models.BaseOperator attribute), [1] describe_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) detect_downstream_cycle() (airflow.models.BaseOperator method), [1] downstream_list (airflow.models.BaseOperator attribute), [1] ds_add() (in module airflow.macros) ds_format() (in module airflow.macros) DummyOperator (class in airflow.operators.dummy_operator)

E

EmailOperator (class in airflow.operators.email_operator) EmrBaseSensor (class in airflow.contrib.sensors.emr_base_sensor) error() (airflow.models.TaskInstance method) execute() (airflow.contrib.operators.spark_sql_operator.SparkSqlOperator method) (airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator method), [1] (airflow.contrib.operators.sqoop_operator.SqoopOperator method) (airflow.models.BaseOperator method), [1] (airflow.operators.bash_operator.BashOperator method)

extra_dejson (airflow.models.Connection attribute)

F

filepath (airflow.models.DAG attribute) find() (airflow.models.DagRun static method)

folder (airflow.models.DAG attribute) FTPHook (class in airflow.contrib.hooks.ftp_hook)

G

generate_command() (airflow.models.TaskInstance static method) GenericTransfer (class in airflow.operators.generic_transfer) get_active_runs() (airflow.models.DAG method) get_conn() (airflow.contrib.hooks.ftp_hook.FTPHook method) (airflow.contrib.hooks.vertica_hook.VerticaHook method) (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.http_hook.HttpHook method) (airflow.hooks.mssql_hook.MsSqlHook method) (airflow.hooks.sqlite_hook.SqliteHook method) get_cursor() (airflow.hooks.dbapi_hook.DbApiHook method) get_dag() (airflow.models.DagBag method) (airflow.models.DagRun method) get_dagrun() (airflow.models.DAG method) (airflow.models.TaskInstance method) get_direct_relatives() (airflow.models.BaseOperator method), [1]

get_first() (airflow.hooks.dbapi_hook.DbApiHook method) get_flat_relatives() (airflow.models.BaseOperator method), [1] get_last_dagrun() (airflow.models.DAG method) get_many() (airflow.models.XCom class method) get_one() (airflow.models.XCom class method) get_pandas_df() (airflow.hooks.dbapi_hook.DbApiHook method) get_previous_dagrun() (airflow.models.DagRun method) get_previous_scheduled_dagrun() (airflow.models.DagRun method) get_records() (airflow.hooks.dbapi_hook.DbApiHook method) get_run() (airflow.models.DagRun static method) get_running_tasks() (airflow.models.DagRun static method) get_task_instance() (airflow.models.DagRun method) get_task_instances() (airflow.models.BaseOperator method), [1] (airflow.models.DagRun method) get_template_env() (airflow.models.DAG method)

H

has_dag() (airflow.models.BaseOperator method), [1] HipChatAPIOperator (class in airflow.contrib.operators.hipchat_operator)

HipChatAPISendRoomNotificationOperator (class in airflow.contrib.operators.hipchat_operator) HttpHook (class in airflow.hooks.http_hook)

I

init_on_load() (airflow.models.TaskInstance method) insert_rows() (airflow.hooks.dbapi_hook.DbApiHook method)

IntervalCheckOperator (class in airflow.operators.check_operator) is_paused (airflow.models.DAG attribute) is_premature (airflow.models.TaskInstance attribute)

K

key (airflow.models.TaskInstance attribute)

kill_zombies() (airflow.models.DagBag method)

L

latest_execution_date (airflow.models.DAG attribute) LatestOnlyOperator (class in airflow.operators.latest_only_operator)

list_directory() (airflow.contrib.hooks.ftp_hook.FTPHook method) LocalExecutor (class in airflow.executors.local_executor) Log (class in airflow.models)

M

max_partition() (in module airflow.macros.hive) MesosExecutor (class in airflow.contrib.executors.mesos_executor)

MsSqlHook (class in airflow.hooks.mssql_hook) MsSqlOperator (class in airflow.operators.mssql_operator)

N

next_retry_datetime() (airflow.models.TaskInstance method)

normalize_schedule() (airflow.models.DAG method)

O

on_kill() (airflow.models.BaseOperator method), [1]

P

PigOperator (class in airflow.operators.pig_operator) pool_full() (airflow.models.TaskInstance method) Popen() (airflow.contrib.hooks.ssh_hook.SSHHook method) post_execute() (airflow.models.BaseOperator method), [1] pre_execute() (airflow.models.BaseOperator method), [1]

prepare_request() (airflow.contrib.operators.hipchat_operator.HipChatAPIOperator method) prepare_template() (airflow.models.BaseOperator method), [1] previous_ti (airflow.models.TaskInstance attribute) process_file() (airflow.models.DagBag method) PythonOperator (class in airflow.operators.python_operator)

R

random() (in module airflow.macros) ready_for_retry() (airflow.models.TaskInstance method) refresh_from_db() (airflow.models.DagRun method) (airflow.models.TaskInstance method) rename() (airflow.contrib.hooks.ftp_hook.FTPHook method) render_template() (airflow.models.BaseOperator method), [1] render_template_from_field() (airflow.models.BaseOperator method), [1]

retrieve_file() (airflow.contrib.hooks.ftp_hook.FTPHook method) run() (airflow.hooks.dbapi_hook.DbApiHook method) (airflow.hooks.http_hook.HttpHook method) (airflow.models.BaseOperator method), [1] (airflow.models.DAG method) (airflow.models.TaskInstance method) run_and_check() (airflow.hooks.http_hook.HttpHook method)

S

schedule_interval (airflow.models.BaseOperator attribute), [1] SequentialExecutor (class in airflow.executors.sequential_executor) set() (airflow.models.XCom class method) set_dependency() (airflow.models.DAG method) set_downstream() (airflow.models.BaseOperator method), [1] set_upstream() (airflow.models.BaseOperator method), [1] ShortCircuitOperator (class in airflow.operators.python_operator) SimpleHttpOperator (class in airflow.operators.http_operator) size() (airflow.models.DagBag method) SlaMiss (class in airflow.models)

SparkSqlOperator (class in airflow.contrib.operators.spark_sql_operator) SparkSubmitOperator (class in airflow.contrib.operators.spark_submit_operator), [1] SqliteHook (class in airflow.hooks.sqlite_hook) SqliteOperator (class in airflow.operators.sqlite_operator) SqoopOperator (class in airflow.contrib.operators.sqoop_operator) SSHHook (class in airflow.contrib.hooks.ssh_hook) store_file() (airflow.contrib.hooks.ftp_hook.FTPHook method) sub_dag() (airflow.models.DAG method) SubDagOperator (class in airflow.operators.subdag_operator) subdags (airflow.models.DAG attribute) sync_to_db() (airflow.models.DAG static method)

T

TaskFail (class in airflow.models) TaskInstance (class in airflow.models) topological_sort() (airflow.models.DAG method)

tree_view() (airflow.models.DAG method) TriggerDagRunOperator (class in airflow.operators.dagrun_operator) tunnel() (airflow.contrib.hooks.ssh_hook.SSHHook method)

U

update_state() (airflow.models.DagRun method)

upstream_list (airflow.models.BaseOperator attribute), [1]

V

ValueCheckOperator (class in airflow.operators.check_operator) verify_integrity() (airflow.models.DagRun method)

VerticaHook (class in airflow.contrib.hooks.vertica_hook) VerticaOperator (class in airflow.contrib.operators.vertica_operator)

X

XCom (class in airflow.models) xcom_pull() (airflow.models.BaseOperator method), [1] (airflow.models.TaskInstance method)

xcom_push() (airflow.models.BaseOperator method), [1] (airflow.models.TaskInstance method)