This is an automated email from the ASF dual-hosted git repository.
potiuk 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 e21eae0f9c Add valid spark on k8s airflow connection urls to tests
(#31376)
e21eae0f9c is described below
commit e21eae0f9c4d0904f23271549b997313054289c9
Author: Amogh Desai <[email protected]>
AuthorDate: Sat Jun 24 13:19:51 2023 +0530
Add valid spark on k8s airflow connection urls to tests (#31376)
---------
Co-authored-by: Amogh <[email protected]>
---
tests/always/test_connection.py | 44 +++++++++++++++++++++++++++++++++++++++++
1 file changed, 44 insertions(+)
diff --git a/tests/always/test_connection.py b/tests/always/test_connection.py
index 70d57df099..b367e98972 100644
--- a/tests/always/test_connection.py
+++ b/tests/always/test_connection.py
@@ -484,6 +484,50 @@ class TestConnection:
schema="",
),
),
+ (
+ "spark://k8s%3a%2F%2F100.68.0.1:443?deploy-mode=cluster",
+ ConnectionParts(
+ conn_type="spark",
+ login=None,
+ password=None,
+ host="k8s://100.68.0.1",
+ port=443,
+ schema="",
+ ),
+ ),
+ (
+
"spark://user:password@k8s%3a%2F%2F100.68.0.1:443?deploy-mode=cluster",
+ ConnectionParts(
+ conn_type="spark",
+ login="user",
+ password="password",
+ host="k8s://100.68.0.1",
+ port=443,
+ schema="",
+ ),
+ ),
+ (
+ "spark://user@k8s%3a%2F%2F100.68.0.1:443?deploy-mode=cluster",
+ ConnectionParts(
+ conn_type="spark",
+ login="user",
+ password=None,
+ host="k8s://100.68.0.1",
+ port=443,
+ schema="",
+ ),
+ ),
+ (
+ "spark://k8s%3a%2F%2Fno.port.com?deploy-mode=cluster",
+ ConnectionParts(
+ conn_type="spark",
+ login=None,
+ password=None,
+ host="k8s://no.port.com",
+ port=None,
+ schema="",
+ ),
+ ),
],
)
def test_connection_from_with_auth_info(self, uri, uri_parts):
