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 f5d7a3a6bb7 Explicitly set extra for connections in generic transfer
tests (#62581)
f5d7a3a6bb7 is described below
commit f5d7a3a6bb7792901388fac614aa3fdcac665648
Author: Amogh Desai <[email protected]>
AuthorDate: Mon Mar 2 13:53:26 2026 +0530
Explicitly set extra for connections in generic transfer tests (#62581)
---
.../sql/tests/unit/common/sql/operators/test_generic_transfer.py | 4 ++--
providers/mysql/tests/unit/mysql/hooks/test_mysql.py | 4 ++--
2 files changed, 4 insertions(+), 4 deletions(-)
diff --git
a/providers/common/sql/tests/unit/common/sql/operators/test_generic_transfer.py
b/providers/common/sql/tests/unit/common/sql/operators/test_generic_transfer.py
index ea94fa4e354..1406542df4e 100644
---
a/providers/common/sql/tests/unit/common/sql/operators/test_generic_transfer.py
+++
b/providers/common/sql/tests/unit/common/sql/operators/test_generic_transfer.py
@@ -89,10 +89,10 @@ class TestMySql:
self.init_client = self.connection.extra_dejson.get("client",
"mysqlclient")
def __enter__(self):
- self.connection.set_extra(f'{{"client": "{self.client}"}}')
+ self.connection.extra = f'{{"client": "{self.client}"}}'
def __exit__(self, exc_type, exc_val, exc_tb):
- self.connection.set_extra(f'{{"client":
"{self.init_client}"}}')
+ self.connection.extra = f'{{"client": "{self.init_client}"}}'
with MySqlContext(client):
sql = "SELECT * FROM connection;"
diff --git a/providers/mysql/tests/unit/mysql/hooks/test_mysql.py
b/providers/mysql/tests/unit/mysql/hooks/test_mysql.py
index 35b3df69763..a0eba90e683 100644
--- a/providers/mysql/tests/unit/mysql/hooks/test_mysql.py
+++ b/providers/mysql/tests/unit/mysql/hooks/test_mysql.py
@@ -619,10 +619,10 @@ class MySqlContext:
self.init_client = self.connection.extra_dejson.get("client",
"mysqlclient")
def __enter__(self):
- self.connection.set_extra(f'{{"client": "{self.client}"}}')
+ self.connection.extra = f'{{"client": "{self.client}"}}'
def __exit__(self, exc_type, exc_val, exc_tb):
- self.connection.set_extra(f'{{"client": "{self.init_client}"}}')
+ self.connection.extra = f'{{"client": "{self.init_client}"}}'
@pytest.mark.backend("mysql")