airflow.contrib.hooks.qubole_hook

Module Contents

airflow.contrib.hooks.qubole_hook.COMMAND_CLASSES

airflow.contrib.hooks.qubole_hook.POSITIONAL_ARGS

airflow.contrib.hooks.qubole_hook.flatten_list(list_of_lists)

airflow.contrib.hooks.qubole_hook.filter_options(options)

airflow.contrib.hooks.qubole_hook.get_options_list(command_class)

airflow.contrib.hooks.qubole_hook.build_command_args()

class airflow.contrib.hooks.qubole_hook.QuboleHook(*args, **kwargs)

Bases: airflow.hooks.base_hook.BaseHook

static handle_failure_retry(context)

execute(self, context)

kill(self, ti)

Kill (cancel) a Qubole command :param ti: Task Instance of the dag, used to determine the Quboles command id :return: response from Qubole

get_results(self, ti=None, fp=None, inline=True, delim=None, fetch=True)

Get results (or just s3 locations) of a command from Qubole and save into a file :param ti: Task Instance of the dag, used to determine the Quboles command id :param fp: Optional file pointer, will create one and return if None passed :param inline: True to download actual results, False to get s3 locations only :param delim: Replaces the CTL-A chars with the given delim, defaults to ‘,’ :param fetch: when inline is True, get results directly from s3 (if large) :return: file location containing actual results or s3 locations of results

get_log(self, ti)

Get Logs of a command from Qubole :param ti: Task Instance of the dag, used to determine the Quboles command id :return: command log as text

get_jobs_id(self, ti)

Get jobs associated with a Qubole commands :param ti: Task Instance of the dag, used to determine the Quboles command id :return: Job information associated with command

get_extra_links(self, operator, dttm)

Get link to qubole command result page.

Parameters

• operator – operator

• dttm – datetime

Returns

url link

create_cmd_args(self, context)