`airflow.providers.vertica.operators.vertica`¶

Module Contents¶

class airflow.providers.vertica.operators.vertica.VerticaOperator(*, sql: Union[str, List[str]], vertica_conn_id: str = 'vertica_default', **kwargs)[source]¶

Bases: airflow.models.BaseOperator

Executes sql code in a specific Vertica database.

Parameters

vertica_conn_id (str) -- reference to a specific Vertica database
sql (Can receive a str representing a sql statement, a list of str (sql statements), or reference to a template file. Template reference are recognized by str ending in '.sql') -- the sql code to be executed. (templated)

template_fields = ['sql'][source]¶

template_ext = ['.sql'][source]¶

ui_color = #b4e0ff[source]¶

execute(self, context: Dict[Any, Any])[source]¶

Was this entry helpful?