dabla commented on code in PR #61143:
URL: https://github.com/apache/airflow/pull/61143#discussion_r2774084290
##########
providers/common/sql/src/airflow/providers/common/sql/triggers/sql.pyi:
##########
@@ -32,11 +32,14 @@
from collections.abc import AsyncIterator
from typing import Any
+from airflow.providers.common.sql.hooks.sql import DbApiHook as DbApiHook
from airflow.triggers.base import BaseTrigger as BaseTrigger, TriggerEvent as
TriggerEvent
class SQLExecuteQueryTrigger(BaseTrigger):
def __init__(
self, sql: str | list[str], conn_id: str, hook_params: dict | None =
None, **kwargs
) -> None: ...
def serialize(self) -> tuple[str, dict[str, Any]]: ...
+ def get_hook(self) -> DbApiHook: ...
+ async def get_records(self) -> Any: ...
Review Comment:
I forgot to remove it, it was public method before, now it's protected
--
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]
