• Home
• Index

Index

_

__aenter__() (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook method) __aexit__() (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook method) __aws_code_commit_regexp__ (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) __detect_repo_provider__() (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator static method) __eq__() (airflow.providers.databricks.hooks.databricks.ClusterState method) (airflow.providers.databricks.hooks.databricks.RunState method)

__git_providers__ (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) __repos_path_regexp__ (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) __repr__() (airflow.providers.databricks.hooks.databricks.ClusterState method) (airflow.providers.databricks.hooks.databricks.RunState method) __version__ (in module airflow.providers.databricks)

A

a_get_cluster_state() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) a_get_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) a_get_run_page_url() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) a_get_run_state() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) airflow.providers.databricks module airflow.providers.databricks.hooks module airflow.providers.databricks.hooks.databricks module airflow.providers.databricks.hooks.databricks_base module airflow.providers.databricks.hooks.databricks_sql module airflow.providers.databricks.operators module airflow.providers.databricks.operators.databricks module airflow.providers.databricks.operators.databricks_repos module

airflow.providers.databricks.operators.databricks_sql module airflow.providers.databricks.sensors module airflow.providers.databricks.sensors.databricks_partition module airflow.providers.databricks.sensors.databricks_sql module airflow.providers.databricks.triggers module airflow.providers.databricks.triggers.databricks module airflow.providers.databricks.utils module airflow.providers.databricks.utils.databricks module AZURE_DEFAULT_AD_ENDPOINT (in module airflow.providers.databricks.hooks.databricks_base) AZURE_MANAGEMENT_ENDPOINT (in module airflow.providers.databricks.hooks.databricks_base) AZURE_METADATA_SERVICE_INSTANCE_URL (in module airflow.providers.databricks.hooks.databricks_base) AZURE_METADATA_SERVICE_TOKEN_URL (in module airflow.providers.databricks.hooks.databricks_base) AZURE_TOKEN_SERVICE_URL (in module airflow.providers.databricks.hooks.databricks_base)

B

BaseDatabricksHook (class in airflow.providers.databricks.hooks.databricks_base) BearerAuth (class in airflow.providers.databricks.hooks.databricks_base)

bulk_dump() (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook method) bulk_load() (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook method)

C

cancel_all_runs() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) CANCEL_ALL_RUNS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) cancel_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) CANCEL_RUN_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) CLUSTER_LIFE_CYCLE_STATES (airflow.providers.databricks.hooks.databricks.ClusterState attribute) ClusterState (class in airflow.providers.databricks.hooks.databricks) conn_id_field (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute)

conn_name_attr (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) conn_type (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) connection_id (in module tests.system.providers.databricks.example_databricks_sensors) (in module tests.system.providers.databricks.example_databricks_sql) COPY_INTO_APPROVED_FORMATS (in module airflow.providers.databricks.operators.databricks_sql) CREATE_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) create_job() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) create_repo() (airflow.providers.databricks.hooks.databricks.DatabricksHook method)

D

DAG_ID (in module tests.system.providers.databricks.example_databricks) (in module tests.system.providers.databricks.example_databricks_repos) (in module tests.system.providers.databricks.example_databricks_sensors) (in module tests.system.providers.databricks.example_databricks_sql) databricks_conn() (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook method) DatabricksCopyIntoOperator (class in airflow.providers.databricks.operators.databricks_sql) DatabricksCreateJobsOperator (class in airflow.providers.databricks.operators.databricks) DatabricksExecutionTrigger (class in airflow.providers.databricks.triggers.databricks) DatabricksHook (class in airflow.providers.databricks.hooks.databricks) DatabricksJobRunLink (class in airflow.providers.databricks.operators.databricks) DatabricksPartitionSensor (class in airflow.providers.databricks.sensors.databricks_partition) DatabricksReposCreateOperator (class in airflow.providers.databricks.operators.databricks_repos) DatabricksReposDeleteOperator (class in airflow.providers.databricks.operators.databricks_repos) DatabricksReposUpdateOperator (class in airflow.providers.databricks.operators.databricks_repos)

DatabricksRunNowDeferrableOperator (class in airflow.providers.databricks.operators.databricks) DatabricksRunNowOperator (class in airflow.providers.databricks.operators.databricks) DatabricksSqlHook (class in airflow.providers.databricks.hooks.databricks_sql) DatabricksSqlOperator (class in airflow.providers.databricks.operators.databricks_sql) DatabricksSqlSensor (class in airflow.providers.databricks.sensors.databricks_sql) DatabricksSubmitRunDeferrableOperator (class in airflow.providers.databricks.operators.databricks) DatabricksSubmitRunOperator (class in airflow.providers.databricks.operators.databricks) default_args (in module tests.system.providers.databricks.example_databricks_repos) default_conn_name (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) DEFAULT_DATABRICKS_SCOPE (in module airflow.providers.databricks.hooks.databricks_base) DEFER_METHOD_NAME (in module airflow.providers.databricks.operators.databricks) delete_repo() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) delete_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) DELETE_RUN_ENDPOINT (in module airflow.providers.databricks.hooks.databricks)

E

encode() (airflow.providers.databricks.hooks.databricks_base.BearerAuth method) ENV_ID (in module tests.system.providers.databricks.example_databricks) (in module tests.system.providers.databricks.example_databricks_repos) (in module tests.system.providers.databricks.example_databricks_sensors) (in module tests.system.providers.databricks.example_databricks_sql) execute() (airflow.providers.databricks.operators.databricks.DatabricksCreateJobsOperator method) (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator method) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunDeferrableOperator method) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator method) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator method) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposDeleteOperator method) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposUpdateOperator method) (airflow.providers.databricks.operators.databricks_sql.DatabricksCopyIntoOperator method)

execute_complete() (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator method) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunDeferrableOperator method) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator method) extra_parameters (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute)

F

find_job_id_by_name() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) find_pipeline_id_by_name() (airflow.providers.databricks.hooks.databricks.DatabricksHook method)

from_json() (airflow.providers.databricks.hooks.databricks.ClusterState class method) (airflow.providers.databricks.hooks.databricks.RunState class method)

G

GET_CLUSTER_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) get_cluster_state() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_conn() (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook method) (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook method) get_db_hook() (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator method) get_job_id() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_link() (airflow.providers.databricks.operators.databricks.DatabricksJobRunLink method) get_repo_by_path() (airflow.providers.databricks.hooks.databricks.DatabricksHook method)

get_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) GET_RUN_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) get_run_output() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_run_page_url() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_run_state() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_run_state_lifecycle() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_run_state_message() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_run_state_result() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_run_state_str() (airflow.providers.databricks.hooks.databricks.DatabricksHook method)

H

hook() (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor method) hook_name (airflow.providers.databricks.hooks.databricks.DatabricksHook attribute) (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook attribute)

host() (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook method)

I

install() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) INSTALL_LIBS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) is_running (airflow.providers.databricks.hooks.databricks.ClusterState property)

is_successful (airflow.providers.databricks.hooks.databricks.RunState property) is_terminal (airflow.providers.databricks.hooks.databricks.ClusterState property) (airflow.providers.databricks.hooks.databricks.RunState property)

J

job (in module tests.system.providers.databricks.example_databricks)

L

list_jobs() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) LIST_JOBS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks)

list_pipelines() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) LIST_PIPELINES_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) LIST_SQL_ENDPOINTS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks_sql)

M

module airflow.providers.databricks airflow.providers.databricks.hooks airflow.providers.databricks.hooks.databricks airflow.providers.databricks.hooks.databricks_base airflow.providers.databricks.hooks.databricks_sql airflow.providers.databricks.operators airflow.providers.databricks.operators.databricks airflow.providers.databricks.operators.databricks_repos airflow.providers.databricks.operators.databricks_sql airflow.providers.databricks.sensors airflow.providers.databricks.sensors.databricks_partition airflow.providers.databricks.sensors.databricks_sql airflow.providers.databricks.triggers airflow.providers.databricks.triggers.databricks airflow.providers.databricks.utils airflow.providers.databricks.utils.databricks tests.system.providers.databricks tests.system.providers.databricks.example_databricks tests.system.providers.databricks.example_databricks_repos tests.system.providers.databricks.example_databricks_sensors tests.system.providers.databricks.example_databricks_sql

N

name (airflow.providers.databricks.operators.databricks.DatabricksJobRunLink attribute)

normalise_json_content() (in module airflow.providers.databricks.utils.databricks)

O

OIDC_TOKEN_SERVICE_URL (in module airflow.providers.databricks.hooks.databricks_base) on_kill() (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator method) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator method)

operator_extra_links (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute) OUTPUT_RUNS_JOB_ENDPOINT (in module airflow.providers.databricks.hooks.databricks)

P

poke() (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor method) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor method)

R

repair_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) REPAIR_RUN_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) repo_path (in module tests.system.providers.databricks.example_databricks_repos) RESET_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) reset_job() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) restart_cluster() (airflow.providers.databricks.hooks.databricks.DatabricksHook method)

RESTART_CLUSTER_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) run() (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook method) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger method) RUN_LIFE_CYCLE_STATES (airflow.providers.databricks.hooks.databricks.RunState attribute) run_now() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) RUN_NOW_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) RunState (class in airflow.providers.databricks.hooks.databricks)

S

serialize() (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger method) SPARK_VERSIONS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) start_cluster() (airflow.providers.databricks.hooks.databricks.DatabricksHook method)

START_CLUSTER_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) submit_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) SUBMIT_RUN_ENDPOINT (in module airflow.providers.databricks.hooks.databricks)

T

T (in module airflow.providers.databricks.hooks.databricks_sql) template_ext (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute) (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute) (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute) template_fields (airflow.providers.databricks.operators.databricks.DatabricksCreateJobsOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposDeleteOperator attribute) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposUpdateOperator attribute) (airflow.providers.databricks.operators.databricks_sql.DatabricksCopyIntoOperator attribute) (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute) (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute) template_fields_renderers (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute) (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute)

terminate_cluster() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) TERMINATE_CLUSTER_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) test_connection() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) test_run (in module tests.system.providers.databricks.example_databricks) (in module tests.system.providers.databricks.example_databricks_repos) (in module tests.system.providers.databricks.example_databricks_sensors) (in module tests.system.providers.databricks.example_databricks_sql) tests.system.providers.databricks module tests.system.providers.databricks.example_databricks module tests.system.providers.databricks.example_databricks_repos module tests.system.providers.databricks.example_databricks_sensors module tests.system.providers.databricks.example_databricks_sql module to_json() (airflow.providers.databricks.hooks.databricks.ClusterState method) (airflow.providers.databricks.hooks.databricks.RunState method) TOKEN_REFRESH_LEAD_TIME (in module airflow.providers.databricks.hooks.databricks_base)

U

ui_color (airflow.providers.databricks.operators.databricks.DatabricksCreateJobsOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute) ui_fgcolor (airflow.providers.databricks.operators.databricks.DatabricksCreateJobsOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute)

uninstall() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) UNINSTALL_LIBS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) update_repo() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) user_agent_header() (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook method) user_agent_value() (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook method)

V

validate_trigger_event() (in module airflow.providers.databricks.utils.databricks)

W

WORKSPACE_GET_STATUS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks)

X

XCOM_JOB_ID_KEY (in module airflow.providers.databricks.operators.databricks)

XCOM_RUN_ID_KEY (in module airflow.providers.databricks.operators.databricks) XCOM_RUN_PAGE_URL_KEY (in module airflow.providers.databricks.operators.databricks)

PreviousNext

Was this entry helpful?