• 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)

__exit__() (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup 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_output() (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) additional_params (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook attribute) airflow.providers.databricks module airflow.providers.databricks.exceptions 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.operators.databricks_workflow module airflow.providers.databricks.plugins module airflow.providers.databricks.plugins.databricks_workflow 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 airflow_app (in module airflow.providers.databricks.plugins.databricks_workflow) appbuilder_views (airflow.providers.databricks.plugins.databricks_workflow.DatabricksWorkflowPlugin attribute) 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)

B

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

branch (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposUpdateOperator attribute) bulk_dump() (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook method) bulk_load() (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook method)

C

caller (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) CALLER (airflow.providers.databricks.operators.databricks.DatabricksNotebookOperator attribute) caller (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute) CALLER (airflow.providers.databricks.operators.databricks.DatabricksTaskOperator attribute) caller (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute) cancel_all_runs() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) CANCEL_ALL_RUNS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) cancel_previous_runs (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) cancel_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) CANCEL_RUN_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) catalog (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook 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)

client_parameters (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute) (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute) CLUSTER_LIFE_CYCLE_STATES (airflow.providers.databricks.hooks.databricks.ClusterState attribute) ClusterState (class in airflow.providers.databricks.hooks.databricks) conn_id (airflow.providers.databricks.operators.databricks_workflow.WorkflowRunMetadata attribute) 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.databricks.example_databricks_sensors) (in module tests.system.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) create_timeout_thread() (in module airflow.providers.databricks.hooks.databricks_sql)

D

dag (in module tests.system.databricks.example_databricks_workflow) DAG_ID (in module tests.system.databricks.example_databricks) (in module tests.system.databricks.example_databricks_repos) (in module tests.system.databricks.example_databricks_sensors) (in module tests.system.databricks.example_databricks_sql) databricks_conn (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook property) databricks_conn_id (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) (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.DatabricksTaskBaseOperator 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.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) DATABRICKS_CONN_ID (in module tests.system.databricks.example_databricks_workflow) DATABRICKS_NOTIFICATION_EMAIL (in module tests.system.databricks.example_databricks_workflow) databricks_repair_reason_new_settings (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) databricks_retry_args (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.DatabricksTaskBaseOperator attribute) databricks_retry_delay (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.DatabricksTaskBaseOperator 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) databricks_retry_limit (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.DatabricksTaskBaseOperator 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)

databricks_run_id (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute) databricks_task_key (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator property) 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) DatabricksNotebookOperator (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) DatabricksRunNowOperator (class in airflow.providers.databricks.operators.databricks) DatabricksSqlExecutionError DatabricksSqlExecutionTimeout 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) DatabricksSubmitRunOperator (class in airflow.providers.databricks.operators.databricks) DatabricksTaskBaseOperator (class in airflow.providers.databricks.operators.databricks) DatabricksTaskOperator (class in airflow.providers.databricks.operators.databricks) DatabricksWorkflowPlugin (class in airflow.providers.databricks.plugins.databricks_workflow) DatabricksWorkflowTaskGroup (class in airflow.providers.databricks.operators.databricks_workflow) default_args (in module tests.system.databricks.example_databricks_repos) DEFAULT_AZURE_CREDENTIAL_SETTING_KEY (in module airflow.providers.databricks.hooks.databricks_base) default_conn_name (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) DEFAULT_DATABRICKS_SCOPE (in module airflow.providers.databricks.hooks.databricks_base) default_view (airflow.providers.databricks.plugins.databricks_workflow.RepairDatabricksTasks attribute) DEFER_METHOD_NAME (in module airflow.providers.databricks.operators.databricks) deferrable (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute) 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) do_xcom_push (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute)

E

encode() (airflow.providers.databricks.hooks.databricks_base.BearerAuth method) ENV_ID (in module tests.system.databricks.example_databricks) (in module tests.system.databricks.example_databricks_repos) (in module tests.system.databricks.example_databricks_sensors) (in module tests.system.databricks.example_databricks_sql) environments (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute) (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) escaper (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) execute() (airflow.providers.databricks.operators.databricks.DatabricksCreateJobsOperator method) (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator method) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator method) (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator 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.DatabricksSubmitRunOperator method) (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator method) EXECUTION_TIMEOUT (in module tests.system.databricks.example_databricks_workflow) existing_cluster_id (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute) existing_clusters (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) extra_job_params (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) extra_parameters (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute)

F

file_location (airflow.providers.databricks.operators.databricks_sql.DatabricksCopyIntoOperator attribute) files (airflow.providers.databricks.operators.databricks_sql.DatabricksCopyIntoOperator attribute) 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_auth_decorator() (in module airflow.providers.databricks.plugins.databricks_workflow) 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_databricks_task_ids() (in module airflow.providers.databricks.plugins.databricks_workflow) get_db_hook() (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator method) get_job_id() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_latest_repair_id() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) get_launch_task_id() (in module airflow.providers.databricks.plugins.databricks_workflow) get_link() (airflow.providers.databricks.operators.databricks.DatabricksJobRunLink method) (airflow.providers.databricks.plugins.databricks_workflow.WorkflowJobRepairAllFailedLink method) (airflow.providers.databricks.plugins.databricks_workflow.WorkflowJobRepairSingleTaskLink method) (airflow.providers.databricks.plugins.databricks_workflow.WorkflowJobRunLink 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) get_task_group_children() (airflow.providers.databricks.plugins.databricks_workflow.WorkflowJobRepairAllFailedLink class method) get_task_instance() (in module airflow.providers.databricks.plugins.databricks_workflow) get_tasks_to_run() (airflow.providers.databricks.plugins.databricks_workflow.WorkflowJobRepairAllFailedLink method) get_xcom_result() (in module airflow.providers.databricks.plugins.databricks_workflow) git_url (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) GROUP_ID (in module tests.system.databricks.example_databricks_workflow)

H

handler (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute) hook (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor property) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) hook_name (airflow.providers.databricks.hooks.databricks.DatabricksHook attribute) (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook attribute) hook_params (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute) (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute)

host (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook property) http_headers (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook 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) http_path (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute)

I

ignore_existing_repo (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) install() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) INSTALL_LIBS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) INTERNAL_ERROR (airflow.providers.databricks.hooks.databricks.RunLifeCycleState attribute) is_databricks (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute)

is_repair_reason_match_exist() (in module airflow.providers.databricks.operators.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

jar_params (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) job (in module tests.system.databricks.example_databricks) job_cluster_key (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute) job_cluster_spec (in module tests.system.databricks.example_databricks_workflow)

job_clusters (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) job_id (airflow.providers.databricks.operators.databricks_workflow.WorkflowRunMetadata attribute) json (airflow.providers.databricks.operators.databricks.DatabricksCreateJobsOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute)

L

life_cycle_state (airflow.providers.databricks.hooks.databricks.RunState attribute) 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

max_concurrent_runs (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) module airflow.providers.databricks airflow.providers.databricks.exceptions 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.operators.databricks_workflow airflow.providers.databricks.plugins airflow.providers.databricks.plugins.databricks_workflow 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.databricks tests.system.databricks.example_databricks tests.system.databricks.example_databricks_repos tests.system.databricks.example_databricks_sensors tests.system.databricks.example_databricks_sql tests.system.databricks.example_databricks_workflow

monitor_databricks_job() (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator method)

N

name (airflow.providers.databricks.operators.databricks.DatabricksJobRunLink attribute) (airflow.providers.databricks.plugins.databricks_workflow.DatabricksWorkflowPlugin attribute) (airflow.providers.databricks.plugins.databricks_workflow.WorkflowJobRepairAllFailedLink attribute) (airflow.providers.databricks.plugins.databricks_workflow.WorkflowJobRepairSingleTaskLink attribute) (airflow.providers.databricks.plugins.databricks_workflow.WorkflowJobRunLink attribute) new_cluster (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute)

normalise_json_content() (in module airflow.providers.databricks.utils.databricks) notebook_packages (airflow.providers.databricks.operators.databricks.DatabricksNotebookOperator attribute) (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) notebook_params (airflow.providers.databricks.operators.databricks.DatabricksNotebookOperator attribute) (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) notebook_path (airflow.providers.databricks.operators.databricks.DatabricksNotebookOperator attribute)

O

oauth_tokens (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) 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) (airflow.providers.databricks.operators.databricks_sql.DatabricksCopyIntoOperator method)

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

P

partition_operator (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) partitions (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) PENDING (airflow.providers.databricks.hooks.databricks.RunLifeCycleState attribute) poke() (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor method) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor method)

polling_period_seconds (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.DatabricksTaskBaseOperator attribute) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) python_params (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute)

Q

QUERY_ID (in module tests.system.databricks.example_databricks) (in module tests.system.databricks.example_databricks_workflow)

QUEUED (airflow.providers.databricks.hooks.databricks.RunLifeCycleState attribute)

R

repair() (airflow.providers.databricks.plugins.databricks_workflow.RepairDatabricksTasks method) repair_databricks_package (in module airflow.providers.databricks.plugins.databricks_workflow) repair_databricks_view (in module airflow.providers.databricks.plugins.databricks_workflow) repair_run (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) repair_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) REPAIR_RUN_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) REPAIR_WAIT_ATTEMPTS (in module airflow.providers.databricks.plugins.databricks_workflow) REPAIR_WAIT_DELAY (in module airflow.providers.databricks.plugins.databricks_workflow) RepairDatabricksTasks (class in airflow.providers.databricks.plugins.databricks_workflow) repo_id (airflow.providers.databricks.operators.databricks_repos.DatabricksReposDeleteOperator attribute) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposUpdateOperator attribute) repo_path (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposDeleteOperator attribute) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposUpdateOperator attribute) (in module tests.system.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) result_state (airflow.providers.databricks.hooks.databricks.RunState attribute) retry_args (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) retry_delay (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) retry_limit (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) run() (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook method) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger method) run_id (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute) (airflow.providers.databricks.operators.databricks_workflow.WorkflowRunMetadata attribute) (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) 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) run_page_url (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger attribute) RunLifeCycleState (class in airflow.providers.databricks.hooks.databricks) RUNNING (airflow.providers.databricks.hooks.databricks.RunLifeCycleState attribute) RunState (class in airflow.providers.databricks.hooks.databricks)

S

schema (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook 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) serialize() (airflow.providers.databricks.triggers.databricks.DatabricksExecutionTrigger method) session_config (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook attribute) (airflow.providers.databricks.operators.databricks_sql.DatabricksCopyIntoOperator attribute) (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute) session_configuration (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute) SKIPPED (airflow.providers.databricks.hooks.databricks.RunLifeCycleState attribute) source (airflow.providers.databricks.operators.databricks.DatabricksNotebookOperator attribute)

spark_submit_params (airflow.providers.databricks.operators.databricks_workflow.DatabricksWorkflowTaskGroup attribute) SPARK_VERSIONS_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) sql (airflow.providers.databricks.sensors.databricks_sql.DatabricksSqlSensor attribute) sql_endpoint_name (airflow.providers.databricks.operators.databricks_sql.DatabricksSqlOperator attribute) start_cluster() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) START_CLUSTER_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) state (airflow.providers.databricks.hooks.databricks.ClusterState attribute) state_message (airflow.providers.databricks.hooks.databricks.ClusterState attribute) (airflow.providers.databricks.hooks.databricks.RunState attribute) submit_run() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) SUBMIT_RUN_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) supports_autocommit (airflow.providers.databricks.hooks.databricks_sql.DatabricksSqlHook attribute)

T

T (in module airflow.providers.databricks.hooks.databricks_sql) table_name (airflow.providers.databricks.operators.databricks_sql.DatabricksCopyIntoOperator attribute) (airflow.providers.databricks.sensors.databricks_partition.DatabricksPartitionSensor attribute) tag (airflow.providers.databricks.operators.databricks_repos.DatabricksReposCreateOperator attribute) (airflow.providers.databricks.operators.databricks_repos.DatabricksReposUpdateOperator attribute) task_config (airflow.providers.databricks.operators.databricks.DatabricksTaskOperator attribute) task_group (in module tests.system.databricks.example_databricks_workflow) 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.DatabricksNotebookOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksTaskOperator 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) TERMINATED (airflow.providers.databricks.hooks.databricks.RunLifeCycleState attribute) TERMINATING (airflow.providers.databricks.hooks.databricks.RunLifeCycleState attribute) test_connection() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) test_run (in module tests.system.databricks.example_databricks) (in module tests.system.databricks.example_databricks_repos) (in module tests.system.databricks.example_databricks_sensors) (in module tests.system.databricks.example_databricks_sql) (in module tests.system.databricks.example_databricks_workflow) tests.system.databricks module tests.system.databricks.example_databricks module tests.system.databricks.example_databricks_repos module tests.system.databricks.example_databricks_sensors module tests.system.databricks.example_databricks_sql module tests.system.databricks.example_databricks_workflow module timeout_seconds (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute) to_json() (airflow.providers.databricks.hooks.databricks.ClusterState method) (airflow.providers.databricks.hooks.databricks.RunState method) token (airflow.providers.databricks.hooks.databricks_base.BearerAuth attribute) TOKEN_REFRESH_LEAD_TIME (in module airflow.providers.databricks.hooks.databricks_base) token_timeout_seconds (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook attribute)

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_ENDPOINT (in module airflow.providers.databricks.hooks.databricks) update_job() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) update_job_for_repair() (in module airflow.providers.databricks.operators.databricks) update_job_permission() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) update_repo() (airflow.providers.databricks.hooks.databricks.DatabricksHook method) USER (in module tests.system.databricks.example_databricks_workflow) user_agent_header (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook property) user_agent_value (airflow.providers.databricks.hooks.databricks_base.BaseDatabricksHook property)

V

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

W

wait_for_termination (airflow.providers.databricks.operators.databricks.DatabricksRunNowOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksSubmitRunOperator attribute) (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute) WAITING_FOR_RETRY (airflow.providers.databricks.hooks.databricks.RunLifeCycleState attribute) WAREHOUSE_ID (in module tests.system.databricks.example_databricks) (in module tests.system.databricks.example_databricks_workflow)

workflow_run_metadata (airflow.providers.databricks.operators.databricks.DatabricksTaskBaseOperator attribute) WorkflowJobRepairAllFailedLink (class in airflow.providers.databricks.plugins.databricks_workflow) WorkflowJobRepairSingleTaskLink (class in airflow.providers.databricks.plugins.databricks_workflow) WorkflowJobRunLink (class in airflow.providers.databricks.plugins.databricks_workflow) WorkflowRunMetadata (class in airflow.providers.databricks.operators.databricks_workflow) 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?