From 4bc7d6f9a435bf9d53d02734f361b757db1d5def Mon Sep 17 00:00:00 2001 From: David Blain Date: Mon, 16 Dec 2024 12:16:56 +0100 Subject: [PATCH] refactor: Reformatted SQLExecuteQueryTrigger definition --- .../airflow/providers/common/sql/triggers/sql.pyi | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/providers/src/airflow/providers/common/sql/triggers/sql.pyi b/providers/src/airflow/providers/common/sql/triggers/sql.pyi index c333364d74f82..ba820099e5b5c 100644 --- a/providers/src/airflow/providers/common/sql/triggers/sql.pyi +++ b/providers/src/airflow/providers/common/sql/triggers/sql.pyi @@ -28,24 +28,20 @@ # You can read more in the README_API.md file # """ -Definition of the public interface for airflow.providers.common.sql.sensors.sql +Definition of the public interface for airflow.providers.common.sql.triggers.sql isort:skip_file """ +from airflow.triggers.base import BaseTrigger, TriggerEvent + from collections.abc import AsyncIterator from typing import Any -from airflow.triggers.base import BaseTrigger, TriggerEvent - class SQLExecuteQueryTrigger(BaseTrigger): def __init__( - self, - sql: str | list[str], - conn_id: str, - hook_params: dict | None = None, - **kwargs, + self, sql: str | list[str], conn_id: str, hook_params: dict | None = None, **kwargs, ) -> None: ... def serialize(self) -> tuple[str, dict[str, Any]]: ... - async def run(self) -> AsyncIterator[TriggerEvent]:... + async def run(self) -> AsyncIterator[TriggerEvent]: ...