docs: def work():
      """Start an rq worker on the connection provided by create_connection."""
      with rq.Connection(create_connection()):
          worker = rq.Worker(list(map(rq.Queue, listen)))
          worker.work()