airflow.providers.trino.operators.trino

This module contains the Trino operator.

Module Contents

Classes

TrinoOperator

Executes sql code using a specific Trino query Engine.
class airflow.providers.trino.operators.trino.TrinoOperator(*, sql, trino_conn_id='trino_default', autocommit=False, parameters=None, handler=None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Executes sql code using a specific Trino query Engine.

See also

For more information on how to use this operator, take a look at the guide: TrinoOperator

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.

  • trino_conn_id (str) – id of the connection config for the target Trino environment

  • autocommit (bool) – What to set the connection’s autocommit setting to before executing the query

  • handler (Callable | None) – The result handler which is called with the result of each statement.

  • parameters (tuple | None) – (optional) the parameters to render the SQL query with.

template_fields :Sequence[str] = ['sql'][source]
template_fields_renderers[source]
template_ext :Sequence[str] = ['.sql'][source]
ui_color = #ededed[source]
get_hook()[source]

Get Trino hook

execute(context)[source]

Execute Trino SQL

on_kill()[source]

Override this method to cleanup subprocesses when a task instance gets killed. Any use of the threading, subprocess or multiprocessing module within an operator needs to be cleaned up or it will leave ghost processes behind.

Was this entry helpful?