code: def test_get_conn_with_schema(
      self, socket_mock, mock_insecure_client, mock_session
  ):
      with patch(
          "airflow.providers.apache.hdfs.hooks.webhdfs.WebHDFSHook.get_connection",
          return_value=Connection(
              host="host_1.com,host_2.com",
              port=321,
              schema="schema",
              login="user",
          ),
      ) as mock_get_connection:
          mock_insecure_client.side_effect = [
              HdfsError("Error"),
              mock_insecure_client.return_value,
          ]
          socket_mock.socket.return_value.connect_ex.return_value = 0
          conn = self.webhdfs_hook.get_conn()
          connection = mock_get_connection.return_value
          hosts = connection.host.split(",")
          mock_insecure_client.assert_has_calls(
              [
                  call(
                      f"http://{host}:{connection.port}/{connection.schema}",
                      user=connection.login,
                      session=mock_session.return_value,
                  )
                  for host in hosts
              ]
          )
          mock_insecure_client.return_value.status.assert_called_once_with(
              "/"
          )
          assert conn == mock_insecure_client.return_value
  
imports: from __future__ import annotations
  from unittest.mock import call, patch
  import pytest
  from hdfs import HdfsError
  from airflow.models.connection import Connection
  from airflow.providers.apache.hdfs.hooks.webhdfs import AirflowWebHDFSHookException, WebHDFSHook
label_desc: Use image node_id 3 for calling the TestWebHDFSHook obj's underlying member method code with example usage: obj.test_get_conn_with_schema(socket_mock, mock_insecure_client, mock_session) without return types