def removeNonprintable(value):

      # expects raw-encoded string, not unicode

      if six.PY2:

      else:

          value = value.translate(NONPRINTABLE_CHARS_TABLE)

  def _fix_print(value):

      logger = logger or logging.getLogger('koji')

      try:

          st = os.lstat(path)

      if not stat.S_ISDIR(st.st_mode):

          raise koji.GenericError("Not a directory: %s" % path)

      dev = st.st_dev

      def test_MultiCallHack_weakref_validation(self):

          expected_exc = 'The session parameter must be a weak reference'

          with self.assertRaisesRegex(TypeError, expected_exc):

              koji.MultiCallHack(self.ksession)

              if not fn.endswith('.data'):

                  continue

              path = os.path.join(datadir, fn)

                  s = fo.read()

                  params = ast.literal_eval(s)

                  expected = fo.read()

              output = koji.genMockConfig(**params)

              self.assertMultiLineEqual(output, expected)

  import unittest

  try:

      import imp

      importlib = None

  import koji

  import koji.util

  import tempfile

  import unittest

  import koji

          self.assertEqual(contents_signed, contents_spliced)

          self.assertNotEqual(contents_signed, contents_orig)

      def test_splice_rpm_sighdr(self):

          contents_signed = open(self.signed, 'rb').read()

          sighdr = koji.rip_rpm_sighdr(self.signed)

      @patch('time.time')

      @patch('time.sleep')

      @patch('signal.pause')

          """Tests timeout behavior in the wait function"""

          temp_path = self.get_tmp_dir_path('TaskTest')

          obj = TaskTest(95, 'some_method', ['random_arg'], None, None, temp_path)

          obj.session = MagicMock()

          obj.session.host.taskWait.return_value = [[], [99, 100, 101]]

          time.side_effect = list(range(0, 4000, 60))

          try:

              obj.wait([99, 100, 101], timeout=3600)

              raise Exception('A GenericError was not raised.')

          except koji.GenericError as e:

              self.assertEqual(e.args[0][:24], 'Subtasks timed out after')

          obj.session.host.taskSetWait.assert_called_once_with(95, [99, 100, 101])

          obj.session.cancelTaskChildren.assert_called_once_with(95)

          obj.session.getTaskResult.assert_not_called()

      @patch('time.time')

      @patch('time.sleep')

      @patch('signal.pause')

          """Tests that timeout does not happen if tasks finish in time"""

          temp_path = self.get_tmp_dir_path('TaskTest')

          obj = TaskTest(95, 'some_method', ['random_arg'], None, None, temp_path)

          # and then report all done

          taskWait_returns.append([[99, 100, 101], []])

          obj.session.host.taskWait.side_effect = taskWait_returns

          obj.wait([99, 100, 101], timeout=3600)

          obj.session.host.taskSetWait.assert_called_once_with(95, [99, 100, 101])

          obj.session.cancelTaskChildren.assert_not_called()

          pause.assert_not_called()

      def _read_conf(self, cfile):

          path = os.path.dirname(__file__)

              if six.PY2:

                  config = six.moves.configparser.SafeConfigParser()

                  config.readfp(conf_file)

          rmtree_nofork.assert_called_once()

          self.assertEqual(rmtree_nofork.call_args[0][0], path)

          _exit.assert_called_once()

      @mock.patch('tempfile.mkstemp')  # avoid stray temp file

      @mock.patch('koji.util._rmtree_nofork')

  # coding=utf-8

  from __future__ import absolute_import

  import re

  from six.moves import xmlrpc_client

  from koji import xmlrpcplus

                       'RegexNameInternal.compiled': re.compile('^[A-Za-z0-9/_.+-]+$')}

          dist_data_output = ({'MaxNameLengthInternal': 15,

                               'RegexNameInternal.compiled': "re.compile('^[A-Za-z0-9/_.+-]+$')"},)

          dict_data = (dict_data,)

          enc = xmlrpcplus.dumps(dict_data, methodresponse=1)

          params, method = xmlrpc_client.loads(enc)

      {envbindir}/coverage2 erase

  commands =

      {envbindir}/coverage2 run --source . -m pytest {posargs:\

          tests/test_plugins/test_runroot_builder.py \

          tests/test_plugins/test_save_failed_tree_builder.py \

          tests/test_plugins/test_runroot_cli.py \