#!/usr/bin/python

  import cProfile

  import fnmatch

  import logging

  import dateutil

  import koji as _koji  # koji declared using profile module in main()

  koji = _koji  # until main() replaces

  import koji.policy

  from koji.util import multi_fnmatch

      # all the work is in subprocesses, so we just wait

      # the order of waiting matters

      logger.info('Waiting for workers to stop.')

      for worker in workers:

      workers_done.set()

      logger.info('Waiting for move queue to clear')

      logger.info('Waiting for movers to stop')

      for mover in movers:

          sys.exit(1)

  def get_session():

      """Get a subsession if logged in, clone session if not"""

      session_opts = koji.grab_session_options(koji.config)

      while True:

          try:

              method, args, kw = stats_queue.get(block=True, timeout=5)

              if workers_done.is_set() and move_queue.empty():

                  # is this enough?

                  break

      while True:

          try:

              build, opts = build_queue.get(block=True, timeout=5)

              if feeder_done.is_set():

                  # is this enough?

                  break

      while True:

          try:

              build, volume, size = move_queue.get(block=True, timeout=5)

              if workers_done.is_set():

                  break

              continue