`airflow.providers.qubole.hooks.qubole_check`¶

Module Contents¶

airflow.providers.qubole.hooks.qubole_check.log[source]¶

airflow.providers.qubole.hooks.qubole_check.COL_DELIM =[source]¶

airflow.providers.qubole.hooks.qubole_check.ROW_DELIM =[source]¶

airflow.providers.qubole.hooks.qubole_check.isint(value) → bool [source]¶
Whether Qubole column are integer

airflow.providers.qubole.hooks.qubole_check.isfloat(value) → bool [source]¶
Whether Qubole column are float

airflow.providers.qubole.hooks.qubole_check.isbool(value) → bool [source]¶
Whether Qubole column are boolean

airflow.providers.qubole.hooks.qubole_check.parse_first_row(row_list) → List[Union[bool, float, int, str]][source]¶
Parse Qubole first record list

class airflow.providers.qubole.hooks.qubole_check.QuboleCheckHook(context, *args, **kwargs)[source]¶

Bases: airflow.providers.qubole.hooks.qubole.QuboleHook

Qubole check hook

static handle_failure_retry(context)[source]¶

get_first(self, sql)[source]¶: Get Qubole query first record list

get_query_results(self)[source]¶: Get Qubole query result

Was this entry helpful?