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 665c061a0ac Make apache cassandra provider compatible with mypy 1.16.1
(#53110)
665c061a0ac is described below
commit 665c061a0acd4f775152a1b36f36852ee0c288f4
Author: Jens Scheffler <[email protected]>
AuthorDate: Wed Jul 9 23:39:42 2025 +0200
Make apache cassandra provider compatible with mypy 1.16.1 (#53110)
---
.../cassandra/src/airflow/providers/apache/cassandra/hooks/cassandra.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/providers/apache/cassandra/src/airflow/providers/apache/cassandra/hooks/cassandra.py
b/providers/apache/cassandra/src/airflow/providers/apache/cassandra/hooks/cassandra.py
index cdf21aad1bf..821e0678213 100644
---
a/providers/apache/cassandra/src/airflow/providers/apache/cassandra/hooks/cassandra.py
+++
b/providers/apache/cassandra/src/airflow/providers/apache/cassandra/hooks/cassandra.py
@@ -100,7 +100,7 @@ class CassandraHook(BaseHook, LoggingMixin):
if conn.login:
conn_config["auth_provider"] =
PlainTextAuthProvider(username=conn.login, password=conn.password)
- policy_name = conn.extra_dejson.get("load_balancing_policy", None)
+ policy_name = str(conn.extra_dejson.get("load_balancing_policy",
"undefined"))
policy_args = conn.extra_dejson.get("load_balancing_policy_args", {})
lb_policy = self.get_lb_policy(policy_name, policy_args)
if lb_policy:
