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 cdf21aad1bf43..821e0678213ae 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 @@ def __init__(self, cassandra_conn_id: str = default_conn_name): 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: