code: def size(self):
          
  
          if self.id.endswith("/"):
              subqueues = self.get_known_subqueues()
              if len(subqueues) == 0:
                  return 0
              else:
                  with context.connections.redis.pipeline(transaction=False) as pipe:
                      for subqueue in subqueues:
                          pipe.get("queuesize:%s" % subqueue)
                      return [int(size or 0) for size in pipe.execute()]
          else:
              return int(context.connections.redis.get("queuesize:%s" % self.id) or 0)
docs: Returns the total number of queued jobs on the queue