airflow.providers.yandex.hooks.yq

Module Contents

Classes

YQHook

A hook for Yandex Query.
class airflow.providers.yandex.hooks.yq.YQHook(*args, **kwargs)[source]

Bases: airflow.providers.yandex.hooks.yandex.YandexCloudBaseHook

A hook for Yandex Query.

close()[source]

Release all resources.

create_query(query_text, name=None)[source]

Create and run query.

Parameters

  • query_text (str | None) – SQL text.

  • name (str | None) – name for the query

wait_results(query_id, execution_timeout=timedelta(minutes=30))[source]

Wait for query complete and get results.

Parameters

  • query_id (str) – ID of query.

  • execution_timeout (datetime.timedelta) – how long to wait for the query to complete.

stop_query(query_id)[source]

Stop the query.

Parameters

query_id (str) – ID of the query.

get_query(query_id)[source]

Get query info.

Parameters

query_id (str) – ID of the query.

get_query_status(query_id)[source]

Get status of the query.

Parameters

query_id (str) – ID of query.

Compose web link to query in Yandex Query UI.

Parameters

query_id (str) – ID of query.

Was this entry helpful?