airflow.providers.ydb.operators.ydb

Module Contents

Classes

YDBExecuteQueryOperator

Executes sql code in a specific YDB database.
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 (Mapping | Iterable | None) – (optional) the parameters to render the SQL query with.

ui_color = '#ededed'[source]

Was this entry helpful?