code: def test_redis_queue_warning():
      my_queue = QueuingSystem.REDIS.get_api_delta_queue(
          queue_id="test_redis_queue_warning"
      )
      my_queue.clear()
      with pytest.warns(UserWarning, match="is larger than the"):
          my_queue.put(None)
          my_queue.put(None)
          my_queue.put(None)
  
imports: import base64
  import multiprocessing
  import pickle
  import queue
  import time
  from unittest import mock
  import pytest
  import requests_mock
  from lightning.app import LightningFlow
  from lightning.app.core import queues
  from lightning.app.core.constants import HTTP_QUEUE_URL, STATE_UPDATE_TIMEOUT
  from lightning.app.core.queues import READINESS_QUEUE_CONSTANT, BaseQueue, HTTPQueue, QueuingSystem, RateLimitedQueue, RedisQueue
  from lightning.app.utilities.imports import _is_redis_available
  from lightning.app.utilities.redis import check_if_redis_running
label_desc: Use image node_id 8 for calling a global function with example usage: test_redis_queue_warning() without return types