This is an automated email from the ASF dual-hosted git repository.
jscheffl pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 3eb4c58f17a Fix Trino Provider intergation test after removal of
deprecations (#44829)
3eb4c58f17a is described below
commit 3eb4c58f17aeeb24a26ca6027a26f136d10a5643
Author: Jens Scheffler <[email protected]>
AuthorDate: Tue Dec 10 23:25:36 2024 +0100
Fix Trino Provider intergation test after removal of deprecations (#44829)
---
providers/tests/integration/trino/hooks/test_trino.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/providers/tests/integration/trino/hooks/test_trino.py
b/providers/tests/integration/trino/hooks/test_trino.py
index 1faf183117b..d5a8b6d938a 100644
--- a/providers/tests/integration/trino/hooks/test_trino.py
+++ b/providers/tests/integration/trino/hooks/test_trino.py
@@ -50,7 +50,9 @@ class TestTrinoHookIntegration:
@mock.patch.dict("os.environ",
AIRFLOW_CONN_TRINO_DEFAULT="trino://airflow@trino:8080/")
def test_openlineage_methods(self):
- op = SQLExecuteQueryOperator(task_id="trino_test", sql="SELECT name
FROM tpch.sf1.customer LIMIT 3")
+ op = SQLExecuteQueryOperator(
+ task_id="trino_test", sql="SELECT name FROM tpch.sf1.customer
LIMIT 3", conn_id="trino_default"
+ )
op.execute({})
lineage = op.get_openlineage_facets_on_start()
assert lineage.inputs[0].namespace == "trino://trino:8080"
