code: def test_async_predict_call_pass_through_with_null_failure_path():
      sagemaker_session = (
          empty_sagemaker_session_with_null_failure_path()
      )
  
      response_body = Mock("body")
      response_body.read = Mock("read", return_value=RETURN_VALUE)
      response_body.close = Mock("close", return_value=None)
  
      sagemaker_session.s3_client = Mock(name="s3_client")
      sagemaker_session.s3_client.get_object = Mock(
          name="get_object",
          return_value={"Body": response_body},
      )
      sagemaker_session.s3_client.put_object = Mock(name="put_object")
  
      predictor_async = AsyncPredictor(
          Predictor(ENDPOINT, sagemaker_session)
      )
  
      sagemaker_session.sagemaker_runtime_client.invoke_endpoint_async = Mock(
          name="invoke_endpoint_async",
          return_value={
              "OutputLocation": ASYNC_OUTPUT_LOCATION,
          },
      )
  
      input_location = "s3://some-input-path"
  
      result = predictor_async.predict(
          input_path=input_location,
      )
  
      assert result == RETURN_VALUE
      assert (
          sagemaker_session.sagemaker_runtime_client.invoke_endpoint_async.called
      )
      assert sagemaker_session.s3_client.get_waiter.called_with(
          "object_exists"
      )
      assert (
          sagemaker_session.sagemaker_client.describe_endpoint.not_called
      )
      assert (
          sagemaker_session.sagemaker_client.describe_endpoint_config.not_called
      )
  
imports: from __future__ import absolute_import
  import pytest
  from mock import Mock
  from sagemaker.async_inference.waiter_config import WaiterConfig
  from sagemaker.predictor import Predictor
  from sagemaker.predictor_async import AsyncPredictor
  from sagemaker.exceptions import AsyncInferenceModelError, PollingTimeoutError
label_desc: Use image node_id 11 for calling a global function with example usage: test_async_predict_call_pass_through_with_null_failure_path() without return types