try:

      import ldap3

  except ImportError:

  client_secrets = None

                  # using the yaml without SCM URL. This should never happen

                  # when building production-ready modules using Koji, but in

                  # theory it is possible.

                  return

              else:

                  raise

          commit = xmd.get("mbs", {}).get("commit")

          scmurl = xmd.get("mbs", {}).get("scmurl")

          if not commit or not scmurl:

              return

          td = None

                  if td is not None:

                      shutil.rmtree(td)

              except Exception as e:

                      "Failed to remove temporary directory {!r}: {}".format(

                          td, str(e)))

                       self.module, tag)

          if not tag_info:

              return

          build = self._get_build()

          # Get our own userID, so we can limit the builds to only modular builds

          user_info = koji_session.getLoggedInUser()

          if not user_info or "id" not in user_info:

              return cls.compute_weights_from_build_time(components)

          mbs_user_id = user_info["id"]

                  continue

              if average_time_to_build < 0:

                  weights[component] = weight

                  continue

  logging.debug("Phasers are set to stun.")

  logging.info("%s tried to build something", username)

  """

      try:

          work_queue_put(wrapped_msg)

      except ValueError as e:

      except AttributeError as e:

          # In the event that `moksha.hub._hub` hasn't yet been initialized, we

          # need to store messages on the side until it becomes available.

          # As a last-ditch effort, try to hang initial messages in the config.

          _initial_messages.append(wrapped_msg)

  import koji

  import fedmsg.consumers

  import moksha.hub

  from module_build_service.utils import module_build_state_from_msg

  import module_build_service.messaging

                     list(self.on_module_change.items()))

          for key, callback in all_fns:

              expected = ['config', 'session', 'msg']

              if argspec != expected:

                  raise ValueError("Callback %r, state %r has argspec %r!=%r" % (

                      callback, key, argspec, expected))

      module_info = build.json()

      if module_info['state'] != msg.module_build_state:

          # This is ok.. it's a race condition we can ignore.

          pass

      build = models.ModuleBuild.from_module_event(session, msg)

      module_info = build.json()

      if module_info['state'] != msg.module_build_state:

          # This is ok.. it's a race condition we can ignore.

          pass

      log.info("%r", build.modulemd)

      if build.state != msg.module_build_state:

          # This is ok.. it's a race condition we can ignore.

          pass

          module_build.transition(config, models.BUILD_STATES['failed'],

                                  "Some components failed to build.")

          session.commit()

          return

      groups = module_build_service.builder.GenericBuilder.default_buildroot_groups(

                  if task_info['state'] == koji.TASK_STATES['CLOSED']:

                      builds = koji_session.listBuilds(taskID=task_id)

                      if not builds:

                      elif len(builds) > 1:

                      else:

                          build_version = builds[0]['version']

                          build_release = builds[0]['release']

                  try:

                      return function(*args, **kwargs)

                  except wait_on as e:

                          e, function, interval))

                      time.sleep(interval)

                      if (time.time() - start) >= timeout:

      try:

          buildrequires = module_build.mmd().get_xmd()['mbs']['buildrequires']

      except (ValueError, KeyError):

          buildrequires = None

      base_module_stream = ''

                  base_module_stream += '+'

                  break

          else:

      return '{prefix}{base_module_stream}{index}+{dist_hash}'.format(

          prefix=conf.default_dist_tag_prefix,

          # No log file should be created.

          log.debug("ignore this test msg")

          log.info("ignore this test msg")

          log.error("ignore this test msg")

          self.build_log.stop(build)

          assert not os.path.exists(path)

          MBSConsumer.current_module_build_id = 1

          log.debug("ignore this test msg1")

          log.info("ignore this test msg1")

          log.error("ignore this test msg1")

          MBSConsumer.current_module_build_id = 2

          log.debug("ignore this test msg2")

          log.info("ignore this test msg2")

          log.error("ignore this test msg2")

          self.build_log.stop(build)

          MBSConsumer.current_module_build_id = 2

          log.debug("ignore this test msg3")

          log.info("ignore this test msg3")

          log.error("ignore this test msg3")

          self.build_log.stop(build)

          with open(path, "r") as f: