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 d9a3b2c1d0d Stubbing missing tests for task sdk integration testing
for variables (#58030)
d9a3b2c1d0d is described below
commit d9a3b2c1d0d428039b683a876b6cb1bdbac3c8de
Author: Amogh Desai <[email protected]>
AuthorDate: Fri Nov 7 19:26:47 2025 +0530
Stubbing missing tests for task sdk integration testing for variables
(#58030)
---
.../task_sdk_tests/test_variable_operations.py | 26 ++++++++++++++++++++++
1 file changed, 26 insertions(+)
diff --git a/task-sdk-tests/tests/task_sdk_tests/test_variable_operations.py
b/task-sdk-tests/tests/task_sdk_tests/test_variable_operations.py
index b60a02579ba..9bb8245f82d 100644
--- a/task-sdk-tests/tests/task_sdk_tests/test_variable_operations.py
+++ b/task-sdk-tests/tests/task_sdk_tests/test_variable_operations.py
@@ -24,6 +24,8 @@ These tests validate the Execution API endpoints for Variable
operations:
from __future__ import annotations
+import pytest
+
from airflow.sdk.api.datamodels._generated import VariableResponse
from airflow.sdk.execution_time.comms import ErrorResponse
from task_sdk_tests import console
@@ -72,3 +74,27 @@ def test_variable_get_not_found(sdk_client):
assert isinstance(response, ErrorResponse)
assert str(response.error).find("VARIABLE_NOT_FOUND") != -1
console.print("[green]✅ Variable get (not found) test passed!")
+
+
[email protected](reason="TODO: Implement Variable set test")
+def test_variable_set(sdk_client):
+ """
+ Test setting variable value.
+
+ Expected: OKResponse with ok=True
+ Endpoint: PUT /execution/variables/{key}
+ """
+ console.print("[yellow]TODO: Implement test_variable_set")
+ raise NotImplementedError("test_variable_set not implemented")
+
+
[email protected](reason="TODO: Implement Variable delete test")
+def test_variable_delete(sdk_client):
+ """
+ Test deleting variable value.
+
+ Expected: OKResponse with ok=True
+ Endpoint: DELETE /execution/variables/{key}
+ """
+ console.print("[yellow]TODO: Implement test_variable_delete")
+ raise NotImplementedError("test_variable_delete not implemented")