astronomer.providers.databricks.hooks.databricks

Module Contents

Classes

DatabricksHookAsync

This class is deprecated and will be removed in 2.0.0.

Attributes

USER_AGENT_HEADER

astronomer.providers.databricks.hooks.databricks.USER_AGENT_HEADER
class astronomer.providers.databricks.hooks.databricks.DatabricksHookAsync(*args, **kwargs)[source]

Bases: airflow.providers.databricks.hooks.databricks.DatabricksHook

This class is deprecated and will be removed in 2.0.0. Use :class: ~airflow.providers.databricks.hooks.databricks.DatabricksHook instead.

async get_run_state_async(run_id)[source]

Retrieves run state of the run using an asynchronous api call. :param run_id: id of the run :return: state of the run

async get_run_response(run_id)[source]

Makes Async API call to get the run state info.

Parameters:

run_id (str) – id of the run

async get_run_output_response(task_run_id)[source]

Retrieves run output of the run.

Parameters:

task_run_id (str) – id of the run