else:

              realpath = path

          try:

          except BaseException:

              logger.error(''.join(traceback.format_exception(*sys.exc_info())))

          """Spawn (or queue) and rmtree job"""

          self.logger.info("Queuing rmtree job for %s", path)

          self.delete_queue.append(path)

      def checkQueue(self):

          finished = [pid for pid in self.delete_pids if self.waitPid(pid)]

          finally:

              session.logout()

      def pruneLocalRepos(self):

          for volinfo in self.session.listVolumes():

              volumedir = pathinfo.volumedir(volinfo['name'])

                  if repo.tryDelete(self.delete_logger):

                      del self.repos[repo.repo_id]

                      n += 1

  def start_currency_checker(session, repomgr):

      return thread

  def main(options, session):

      repomgr = RepoManager(options, session)

      repomgr.readCurrentRepos()

          curr_ext_chk_thread = start_external_currency_checker(session, repomgr)

      regen_thread = start_regen_loop(session, repomgr)

      delete_thread = start_delete_loop(session, repomgr)

      # TODO also move rmtree jobs to threads

      logger.info("Entering main loop")

      while True:

          try:

              repomgr.updateRepos()

              repomgr.printState()

              repomgr.pruneLocalRepos()

              if not curr_chk_thread.is_alive():

              if not delete_thread.is_alive():

                  logger.error("Delete thread died. Restarting it.")

                  delete_thread = start_delete_loop(session, repomgr)

          except KeyboardInterrupt:

              logger.warning("User exit")

              break