code: def mock_create_tags(provider, batch_updates):
      # Increment batches sent.
      provider.batch_counter += 1
      # Increment tags updated.
      provider.tag_update_counter += sum(
          len(batch_updates[x]) for x in batch_updates
      )
  
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 a global function with example usage: mock_create_tags(provider, batch_updates) without return types