diff --git a/airflow-core/src/airflow/cli/commands/connection_command.py b/airflow-core/src/airflow/cli/commands/connection_command.py index aace3f9c9aede..9d2358b029b3d 100644 --- a/airflow-core/src/airflow/cli/commands/connection_command.py +++ b/airflow-core/src/airflow/cli/commands/connection_command.py @@ -369,7 +369,7 @@ def connections_test(args) -> None: print(f"Retrieving connection: {args.conn_id!r}") try: - conn = BaseHook.get_connection(args.conn_id) + conn = Connection.get_connection_from_secrets(args.conn_id) except AirflowNotFoundException: console.print("[bold yellow]\nConnection not found.\n") raise SystemExit(1)