airflow.providers.oracle.operators.oracle

Module Contents

Classes

OracleStoredProcedureOperator

Executes stored procedure in a specific Oracle database.
class airflow.providers.oracle.operators.oracle.OracleStoredProcedureOperator(*, procedure, oracle_conn_id='oracle_default', parameters=None, **kwargs)[source]

Bases: airflow.models.BaseOperator

Executes stored procedure in a specific Oracle database.

Parameters

  • procedure (str) – name of stored procedure to call (templated)

  • oracle_conn_id (str) – The Oracle connection id reference to a specific Oracle database.

  • parameters (dict | list | None) – (optional, templated) the parameters provided in the call

If do_xcom_push is True, the numeric exit code emitted by the database is pushed to XCom under key ORA in case of failure.

template_fields: collections.abc.Sequence[str] = ('parameters', 'procedure')[source]
ui_color = '#ededed'[source]
execute(context)[source]

Derive when creating an operator.

Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

Was this entry helpful?