code: def test_concurrent(self):
      num_threads = 100
      batches_sent, tags_updated = batch_test(num_threads, delay=0)
      self.assertLess(batches_sent, num_threads / 10)
      self.assertEqual(tags_updated, num_threads)
  
file_path: ray/python/ray/tests/aws/test_aws_batch_tag_update.py
imports: import threading
  import time
  import unittest
  from unittest import mock
  import pytest
  from ray.autoscaler._private.aws.node_provider import AWSNodeProvider
  from ray.autoscaler._private.aws.node_provider import TAG_BATCH_DELAY
label_desc: Use image node_id 1 for calling the TagBatchTest obj's underlying member method code with example usage: obj.test_concurrent() without return types