code: def queues():
      
      conn = worker.connection
      failure_q = None
  
      def _repr(q):
          return "running:%d pending:%d finished:%d" % (
              StartedJobRegistry(q.name, conn).count,
              q.count,
              FinishedJobRegistry(q.name, conn).count)
      for q in Queue.all(conn):
          if q.name == 'failed':
              failure_q = q
              continue
          click.echo("%s %s" % (q.name, _repr(q)))
      if failure_q:
          click.echo(
              click.style(failure_q.name, fg='red') + ' %s' % _repr(failure_q))
docs: Report on progress by queues.