This is an automated email from the ASF dual-hosted git repository.
mobuchowski pushed a commit to branch strip-overzealous-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 97416c5ab711021053b01d862c51862a5e0cd332
Author: Maciej Obuchowski <obuchowski.mac...@gmail.com>
AuthorDate: Tue Jul 16 21:39:12 2024 +0200
openlineage: strip returned SQL statements
Signed-off-by: Maciej Obuchowski <obuchowski.mac...@gmail.com>
---
airflow/providers/openlineage/sqlparser.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow/providers/openlineage/sqlparser.py
b/airflow/providers/openlineage/sqlparser.py
index a76808fdd7..869963b48a 100644
--- a/airflow/providers/openlineage/sqlparser.py
+++ b/airflow/providers/openlineage/sqlparser.py
@@ -322,7 +322,7 @@ class SQLParser(LoggingMixin):
@classmethod
def normalize_sql(cls, sql: list[str] | str) -> str:
"""Make sure to return a semicolon-separated SQL statement."""
- return ";\n".join(stmt.rstrip(" ;\r\n") for stmt in
cls.split_sql_string(sql))
+ return ";\n".join(stmt.rstrip(" ;\r\n") for stmt in
cls.split_sql_string(sql)).strip()
@classmethod
def split_sql_string(cls, sql: list[str] | str) -> list[str]:
