code: def test_redis_queue():
      queue_id = int(time.time())
      queue1 = QueuingSystem.REDIS.get_readiness_queue(
          queue_id=str(queue_id)
      )
      queue2 = QueuingSystem.REDIS.get_readiness_queue(
          queue_id=str(queue_id + 1)
      )
      queue1.put("test_entry1")
      queue2.put("test_entry2")
      assert queue1.get() == "test_entry1"
      assert queue2.get() == "test_entry2"
      with pytest.raises(queue.Empty):
          queue2.get(timeout=1)
      queue1.put("test_entry1")
      assert queue1.length() == 1
      queue1.clear()
      with pytest.raises(queue.Empty):
          queue1.get(timeout=1)
  
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 2 for calling a global function with example usage: test_redis_queue() without return types