code: def __enqueue_data(self, data):
      inf = self.db.info()
      try:
          if (
              inf["used_memory"]
              >= inf["maxmemory"] * self.input_threshold
              and inf["maxmemory"] != 0
          ):
              invalidInputError(False, "redis connetion error")
          self.db.xadd(self.name, data)
          print("Write to Redis successful")
      except redis.exceptions.ConnectionError:
          print(
              "Redis queue is full, please wait for inference "
              "or delete the unprocessed records."
          )
          time.sleep(self.interval_if_error)
  
      except redis.exceptions.ResponseError as e:
          print(
              e,
              "Please check if Redis version > 5, "
              "if yes, memory may be full, try dequeue or delete.",
          )
          time.sleep(self.interval_if_error)
  
imports: import redis
  import time
  from bigdl.serving.schema import *
  import httpx
  import json
  import uuid
  from bigdl.serving.log4Error import invalidInputError
label_desc: Use image node_id 6 for calling the InputQueue obj's underlying member method code with example usage: obj.__enqueue_data(data) without return types