code: def subscribe(self, queue=None, *levels):
          
          args = {
              'queue': queue,
              'levels': list(levels),
          }
  
          self._subscribe_chk.check(args)
  
          return self._client.json('logger.subscribe', args)
docs: Subscribe to the aggregated log stream. On subscribe a ledis queue will be fed with all running processes
          logs. Always use the returned queue name from this method, even if u specified the queue name to use
  
          Note: it is legal to subscribe to the same queue, but would be a bad logic if two processes are trying to
          read from the same queue.
  
          :param queue: Your unique queue name, otherwise, a one will get generated for your
          :param levels:
          :return: queue name to pull from