Hubwiz.com
|
Online Course
|
API Manual
Airflow API Manual
Class(45)
Method(108)
Module(2)
Function(6)
Attribute(15)
Class
airflow.contrib.executors.mesos_executor.MesosExecutor
airflow.contrib.hooks.ftp_hook.FTPHook
airflow.contrib.hooks.ssh_hook.SSHHook
airflow.contrib.hooks.vertica_hook.VerticaHook
airflow.contrib.operators.hipchat_operator.HipChatAPIOperator
airflow.contrib.operators.hipchat_operator.HipChatAPISendRoomNotificationOperator
airflow.contrib.operators.spark_sql_operator.SparkSqlOperator
airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator
airflow.contrib.operators.sqoop_operator.SqoopOperator
airflow.contrib.operators.vertica_operator.VerticaOperator
airflow.contrib.sensors.emr_base_sensor.EmrBaseSensor
airflow.executors.local_executor.LocalExecutor
airflow.executors.sequential_executor.SequentialExecutor
airflow.hooks.dbapi_hook.DbApiHook
airflow.hooks.http_hook.HttpHook
airflow.hooks.mssql_hook.MsSqlHook
airflow.hooks.sqlite_hook.SqliteHook
airflow.models.BaseOperator
airflow.models.Connection
airflow.models.DAG
airflow.models.DagBag
airflow.models.DagPickle
airflow.models.DagRun
airflow.models.Log
airflow.models.SlaMiss
airflow.models.TaskFail
airflow.models.TaskInstance
airflow.models.XCom
airflow.operators.bash_operator.BashOperator
airflow.operators.check_operator.CheckOperator
airflow.operators.check_operator.IntervalCheckOperator
airflow.operators.check_operator.ValueCheckOperator
airflow.operators.dagrun_operator.TriggerDagRunOperator
airflow.operators.dummy_operator.DummyOperator
airflow.operators.email_operator.EmailOperator
airflow.operators.generic_transfer.GenericTransfer
airflow.operators.http_operator.SimpleHttpOperator
airflow.operators.latest_only_operator.LatestOnlyOperator
airflow.operators.mssql_operator.MsSqlOperator
airflow.operators.pig_operator.PigOperator
airflow.operators.python_operator.BranchPythonOperator
airflow.operators.python_operator.PythonOperator
airflow.operators.python_operator.ShortCircuitOperator
airflow.operators.sqlite_operator.SqliteOperator
airflow.operators.subdag_operator.SubDagOperator
Method
airflow.contrib.hooks.ftp_hook.FTPHook.close_conn
airflow.contrib.hooks.ftp_hook.FTPHook.create_directory
airflow.contrib.hooks.ftp_hook.FTPHook.delete_directory
airflow.contrib.hooks.ftp_hook.FTPHook.delete_file
airflow.contrib.hooks.ftp_hook.FTPHook.describe_directory
airflow.contrib.hooks.ftp_hook.FTPHook.get_conn
airflow.contrib.hooks.ftp_hook.FTPHook.list_directory
airflow.contrib.hooks.ftp_hook.FTPHook.rename
airflow.contrib.hooks.ftp_hook.FTPHook.retrieve_file
airflow.contrib.hooks.ftp_hook.FTPHook.store_file
airflow.contrib.hooks.ssh_hook.SSHHook.Popen
airflow.contrib.hooks.ssh_hook.SSHHook.check_output
airflow.contrib.hooks.ssh_hook.SSHHook.tunnel
airflow.contrib.hooks.vertica_hook.VerticaHook.get_conn
airflow.contrib.operators.hipchat_operator.HipChatAPIOperator.prepare_request
airflow.contrib.operators.spark_sql_operator.SparkSqlOperator.execute
airflow.contrib.operators.spark_submit_operator.SparkSubmitOperator.execute
airflow.contrib.operators.sqoop_operator.SqoopOperator.execute
airflow.hooks.dbapi_hook.DbApiHook.bulk_dump
airflow.hooks.dbapi_hook.DbApiHook.bulk_load
airflow.hooks.dbapi_hook.DbApiHook.get_conn
airflow.hooks.dbapi_hook.DbApiHook.get_cursor
airflow.hooks.dbapi_hook.DbApiHook.get_first
airflow.hooks.dbapi_hook.DbApiHook.get_pandas_df
airflow.hooks.dbapi_hook.DbApiHook.get_records
airflow.hooks.dbapi_hook.DbApiHook.insert_rows
airflow.hooks.dbapi_hook.DbApiHook.run
airflow.hooks.http_hook.HttpHook.get_conn
airflow.hooks.http_hook.HttpHook.run
airflow.hooks.http_hook.HttpHook.run_and_check
airflow.hooks.mssql_hook.MsSqlHook.get_conn
airflow.hooks.sqlite_hook.SqliteHook.get_conn
airflow.models.BaseOperator.clear
airflow.models.BaseOperator.detect_downstream_cycle
airflow.models.BaseOperator.execute
airflow.models.BaseOperator.get_direct_relatives
airflow.models.BaseOperator.get_flat_relatives
airflow.models.BaseOperator.get_task_instances
airflow.models.BaseOperator.has_dag
airflow.models.BaseOperator.on_kill
airflow.models.BaseOperator.post_execute
airflow.models.BaseOperator.pre_execute
airflow.models.BaseOperator.prepare_template
airflow.models.BaseOperator.render_template
airflow.models.BaseOperator.render_template_from_field
airflow.models.BaseOperator.run
airflow.models.BaseOperator.set_downstream
airflow.models.BaseOperator.set_upstream
airflow.models.BaseOperator.xcom_pull
airflow.models.BaseOperator.xcom_push
airflow.models.DAG.add_task
airflow.models.DAG.add_tasks
airflow.models.DAG.clear
airflow.models.DAG.cli
airflow.models.DAG.crawl_for_tasks
airflow.models.DAG.create_dagrun
airflow.models.DAG.get_active_runs
airflow.models.DAG.get_dagrun
airflow.models.DAG.get_last_dagrun
airflow.models.DAG.get_template_env
airflow.models.DAG.normalize_schedule
airflow.models.DAG.run
airflow.models.DAG.set_dependency
airflow.models.DAG.sub_dag
airflow.models.DAG.topological_sort
airflow.models.DAG.tree_view
airflow.models.DagBag.bag_dag
airflow.models.DagBag.collect_dags
airflow.models.DagBag.dagbag_report
airflow.models.DagBag.get_dag
airflow.models.DagBag.kill_zombies
airflow.models.DagBag.process_file
airflow.models.DagBag.size
airflow.models.DagRun.get_dag
airflow.models.DagRun.get_previous_dagrun
airflow.models.DagRun.get_previous_scheduled_dagrun
airflow.models.DagRun.get_task_instance
airflow.models.DagRun.get_task_instances
airflow.models.DagRun.refresh_from_db
airflow.models.DagRun.update_state
airflow.models.DagRun.verify_integrity
airflow.models.TaskInstance.are_dependencies_met
airflow.models.TaskInstance.are_dependents_done
airflow.models.TaskInstance.clear_xcom_data
airflow.models.TaskInstance.command
airflow.models.TaskInstance.command_as_list
airflow.models.TaskInstance.current_state
airflow.models.TaskInstance.error
airflow.models.TaskInstance.get_dagrun
airflow.models.TaskInstance.init_on_load
airflow.models.TaskInstance.next_retry_datetime
airflow.models.TaskInstance.pool_full
airflow.models.TaskInstance.ready_for_retry
airflow.models.TaskInstance.refresh_from_db
airflow.models.TaskInstance.run
airflow.models.TaskInstance.xcom_pull
airflow.models.TaskInstance.xcom_push
airflow.operators.bash_operator.BashOperator.execute
airflow.models.DAG.deactivate_stale_dags
airflow.models.DAG.deactivate_unknown_dags
airflow.models.DAG.sync_to_db
airflow.models.DagRun.find
airflow.models.DagRun.get_run
airflow.models.DagRun.get_running_tasks
airflow.models.TaskInstance.generate_command
airflow.models.XCom.get_many
airflow.models.XCom.get_one
airflow.models.XCom.set
Module
airflow.macros
airflow.models
Function
airflow.macros.ds_add
airflow.macros.ds_format
airflow.macros.hive.closest_ds_partition
airflow.macros.hive.max_partition
airflow.macros.random
airflow.models.clear_task_instances
Attribute
airflow.models.BaseOperator.dag
airflow.models.BaseOperator.deps
airflow.models.BaseOperator.downstream_list
airflow.models.BaseOperator.schedule_interval
airflow.models.BaseOperator.upstream_list
airflow.models.Connection.extra_dejson
airflow.models.DAG.concurrency_reached
airflow.models.DAG.filepath
airflow.models.DAG.folder
airflow.models.DAG.is_paused
airflow.models.DAG.latest_execution_date
airflow.models.DAG.subdags
airflow.models.TaskInstance.is_premature
airflow.models.TaskInstance.key
airflow.models.TaskInstance.previous_ti
Class
Method
Module
Function
Attribute
Class(45)
Method(108)
Module(2)
Function(6)
Attribute(15)