airflow.providers.ydb.operators.ydb¶

Classes¶

YDBExecuteQueryOperator

Executes sql code in a specific YDB database.

Module Contents¶

class airflow.providers.ydb.operators.ydb.YDBExecuteQueryOperator(sql, is_ddl=False, ydb_conn_id='ydb_default', parameters=None, **kwargs)[source]¶

Bases: airflow.providers.common.sql.operators.sql.SQLExecuteQueryOperator

Executes sql code in a specific YDB database.

Parameters:

sql (str | list[str]) – the SQL code to be executed as a single string, or a list of str (sql statements), or a reference to a template file. Template references are recognized by str ending in ‘.sql’
ydb_conn_id (str) – The ydb conn id reference to a specific YDB cluster and database.
parameters (collections.abc.Mapping | collections.abc.Iterable | None) – (optional) the parameters to render the SQL query with.

ui_color = '#ededed'[source]¶