Taragolis commented on code in PR #39217:
URL: https://github.com/apache/airflow/pull/39217#discussion_r1602980261
##########
airflow/providers/teradata/operators/teradata.py:
##########
@@ -62,3 +66,38 @@ def __init__(
}
super().__init__(**kwargs)
self.conn_id = conn_id
+
+
+class TeradataStoredProcedureOperator(BaseOperator):
+ """
+ Executes stored procedure in a specific Teradata database.
+
+ :param procedure: name of stored procedure to call (templated)
+ :param conn_id: The :ref:`Teradata connection id
<howto/connection:teradata>`
+ reference to a specific Teradata database.
+ :param parameters: (optional, templated) the parameters provided in the
call
+
+ """
+
+ template_fields: Sequence[str] = (
+ "procedure",
+ "parameters",
+ )
+ ui_color = "#ededed"
+
+ def __init__(
+ self,
+ *,
+ procedure: str,
+ conn_id: str = TeradataHook.default_conn_name,
Review Comment:
I thought better to use `teradata_conn_id` instead rather than generic
`conn_id`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
