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

Module Contents¶

Qubole check hook

`isint`(value) → bool	Whether Qubole column are integer
`isfloat`(value) → bool	Whether Qubole column are float
`isbool`(value) → bool	Whether Qubole column are boolean
`parse_first_row`(row_list) → List[Union[bool, float, int, str]]	Parse Qubole first record list

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]¶

Qubole check hook

static handle_failure_retry(context) → None[source]¶: Handle retries in case of failures