airflow.providers.common.sql.decorators.sql

Functions

sql_task([python_callable])

Wrap a Python function into a SQLExecuteQueryOperator.

Module Contents

airflow.providers.common.sql.decorators.sql.sql_task(python_callable=None, **kwargs)[source]

Wrap a Python function into a SQLExecuteQueryOperator.

Parameters:

python_callable – Function to decorate.

Was this entry helpful?