code: def _assert_tags_match(
      sagemaker_client, resource_arn, tags, retry_count=15
  ):
      # endpoint and training tags might take minutes to propagate.
      for _ in retries(
          retry_count, "Getting endpoint tags", seconds_to_sleep=30
      ):
          actual_tags = sagemaker_client.list_tags(
              ResourceArn=resource_arn
          )["Tags"]
          if actual_tags:
              break
  
      assert actual_tags == tags
  
imports: from __future__ import absolute_import
  import numpy
  import os
  import time
  import pytest
  from sagemaker.serverless import ServerlessInferenceConfig
  from sagemaker.tensorflow import TensorFlow, TensorFlowProcessor, TensorFlowModel
  from sagemaker.utils import unique_name_from_base, sagemaker_timestamp
  import tests.integ
  from tests.integ import DATA_DIR, TRAINING_DEFAULT_TIMEOUT_MINUTES, kms_utils, timeout
  from tests.integ.retry import retries
  from tests.integ.utils import gpu_list, retry_with_instance_list
  from tests.integ.s3_utils import assert_s3_file_patterns_exist
  from packaging.version import Version
label_desc: Use image node_id 11 for calling a global function with example usage: _assert_tags_match(sagemaker_client, resource_arn, tags, retry_count) without return types