code: def _invoke_endpoint(
      self,
      body: Any,
      content_type: ContentType,
  ) -> Dict[str, Any]:
      response = self.sagemaker_runtime_client.invoke_endpoint(
          EndpointName=self.endpoint_name,
          ContentType=content_type.value,
          Body=body,
      )
      return json.loads(response["Body"].read())
  
imports: from __future__ import absolute_import
  import functools
  import json
  import uuid
  from typing import Any, Dict, List, Tuple
  import boto3
  import pandas
  import os
  from botocore.config import Config
  import pytest
  from tests.integ.sagemaker.jumpstart.constants import TEST_ASSETS_SPECS, TMP_DIRECTORY_PATH, TRAINING_DATASET_MODEL_DICT, ContentType
  from sagemaker.jumpstart.constants import JUMPSTART_DEFAULT_REGION_NAME
  from sagemaker.jumpstart.utils import get_jumpstart_content_bucket
  from sagemaker.session import Session
label_desc: Use image node_id 2 for calling the EndpointInvoker obj's underlying member method code with example usage: obj._invoke_endpoint(body, content_type) and returns: json