This is an automated email from the ASF dual-hosted git repository.
amoghdesai 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 e6d650bac62 Stubbing missing tests for task sdk integration testing
for connection (#58029)
e6d650bac62 is described below
commit e6d650bac627f70488c9f440b843d3040cce67c5
Author: Amogh Desai <[email protected]>
AuthorDate: Fri Nov 7 19:27:21 2025 +0530
Stubbing missing tests for task sdk integration testing for connection
(#58029)
---
.../tests/task_sdk_tests/test_connection_operations.py | 14 ++++++++++++++
1 file changed, 14 insertions(+)
diff --git a/task-sdk-tests/tests/task_sdk_tests/test_connection_operations.py
b/task-sdk-tests/tests/task_sdk_tests/test_connection_operations.py
index ffd16ff756c..a90a88cdb22 100644
--- a/task-sdk-tests/tests/task_sdk_tests/test_connection_operations.py
+++ b/task-sdk-tests/tests/task_sdk_tests/test_connection_operations.py
@@ -26,6 +26,8 @@ Prerequisites:
from __future__ import annotations
+import pytest
+
from airflow.sdk.api.datamodels._generated import ConnectionResponse
from task_sdk_tests import console
@@ -55,3 +57,15 @@ def test_connection_get(sdk_client):
assert response.host == "testhost"
assert response.schema_ == "testdb"
console.print("[green]✅ Connection get test passed!")
+
+
[email protected](reason="TODO: Implement Connection get (not found) test")
+def test_connection_get_not_found(sdk_client):
+ """
+ Test getting a non-existent connection.
+
+ Expected: ErrorResponse with CONNECTION_NOT_FOUND error
+ Endpoint: GET /execution/connections/{conn_id}
+ """
+ console.print("[yellow]TODO: Implement test_connection_get_not_found")
+ raise NotImplementedError("test_connection_get_not_found not implemented")
