nvr_dict = kobo.rpmlib.parse_nvr(component_build.nvr)

          # Trigger a completed build message

          args = (

              koji.BUILD_STATES["COMPLETE"], component_build.package, nvr_dict["version"],

              nvr_dict["release"], component_build.module_build.id, None)

          events.scheduler.add(build_task_finalize_handler, args)

                  'The build being skipped isn\'t tagged in the "{0}" tag. Will send a message to '

                  "the tag handler".format(tag)

              )

              events.scheduler.add(tagged_handler, args)

          return True

          except ValueError:

              nvr = {"name": source, "release": "unknown", "version": "unknown"}

          args = (

              nvr["release"], None, None)

          events.scheduler.add(build_task_finalize_handler, args)

  @celery_app.task

  @events.mbs_event_handler

  def build_task_finalize(

          build_name, build_version, build_release,

          module_build_id=None, state_reason=None

  ):

      :param str msg_id: the original id of the message being handled which is

          received from the message bus.

      :param int task_id: the Koji build task id.

      :param int build_new_state: the state of the build. Refer to

          ``koji.BUILD_STATES`` for details. For this handler, values could be

  @celery_app.task

  @events.mbs_event_handler

      """Called whenever koji tags a build to tag.

      :param str msg_id: the original id of the message being handled which is

          received from the message bus.

      :param str tag_name: the tag name applied.

      :param str build_nvr: nvr of the tagged build.

      """

      if conf.system not in ("koji", "test"):

                      return {

                          "msg_id": msg_id,

                          "event": events.KOJI_BUILD_CHANGE,

                          "task_id": task_id,

                          "build_new_state": msg_inner_msg.get("new"),

                          "build_name": msg_inner_msg.get("name"),

                          "msg_id": msg_id,

                          "event": events.KOJI_TAG_CHANGE,

                          "tag_name": msg_inner_msg.get("tag"),

                          "build_nvr": nvr,

                      }

                  log.info(

                      "Apply tag %s to module build %r",

                      module_build.koji_tag, module_build)

              # If it is tagged in the build tag, but MBS does not think so,

              # schedule fake message.

                  log.info(

                      "Apply build tag %s to module build %r",

                      build_tag, module_build)

  @celery_app.task

      # Add this event to scheduler so that the reused component will be tagged properly.

      if schedule_fake_events:

          args = (

              nvr_dict["name"], nvr_dict["version"], nvr_dict["release"], component.module_id,

              component.state_reason)

          events.scheduler.add(build_task_finalize_handler, args)

              FakeModuleBuilder.on_buildroot_add_artifacts_cb(self, artifacts, install)

          if self.backend == "test":

              for nvr in artifacts:

                  # When INSTANT_COMPLETE is on, the components are already in the build tag

                  if self.INSTANT_COMPLETE is False:

          elif self.backend == "testlocal":

              self._send_repo_done()

              for nvr in artifacts:

                  # tag_artifacts received a list of NVRs, but the tag message expects the

                  # component name

      @property

      def koji_session(self):

      def _send_repo_done(self):

          events.scheduler.add(repos_done_handler, ("fake_msg", self.tag_name + "-build"))

          if dest_tag:

              tag = self.tag_name

          else:

              tag = self.tag_name + "-build"

      def _send_build_change(self, state, name, build_id):

          # build_id=1 and task_id=1 are OK here, because we are building just

          # one RPM at the time.

          events.scheduler.add(build_task_finalize_handler, args)

      def build(self, artifact_name, source):

              component_build.state_reason = "Found existing build"

              nvr_dict = kobo.rpmlib.parse_nvr(component_build.nvr)

              # Send a message stating the build is complete

                      component_build.task_id, koji.BUILD_STATES["COMPLETE"],

                      component_build.package, nvr_dict["version"], nvr_dict["release"],

                      component_build.module_build.id, None)

              # Send a message stating that the build was tagged in the build tag

              args = ("recover_orphaned_artifact: fake message",

                      component_build.module_build.koji_tag + "-build",

              events.scheduler.add(tagged_handler, args)

              return True

      @pytest.mark.parametrize("mmd_version", [1, 2])

      @patch("module_build_service.auth.get_user", return_value=user)

      @patch("module_build_service.scm.SCM")

          self, mocked_scm, mocked_get_user, conf_system, dbg, hmsc, mmd_version

      ):

          """

          assert recovered

          event_info = events.scheduler.queue[0][3]

                                'rubygem-rails', '1.0', '1.module+e0095747', 4, None)

          event_info = events.scheduler.queue[1][3]

          assert event_info == ('recover_orphaned_artifact: fake message', 'module-foo-build',

          event_info = events.scheduler.queue[2][3]

          assert event_info == ('recover_orphaned_artifact: fake message', 'module-foo',

          assert component_build.state == koji.BUILD_STATES["COMPLETE"]

          assert component_build.task_id == 12345

          assert recovered

          event_info = events.scheduler.queue[0][3]

                                'rubygem-rails', '1.0', '1.module+2+b8661ee4', 4, None)

          assert component_build.state == koji.BUILD_STATES["COMPLETE"]

          assert recovered

          event_info = events.scheduler.queue[0][3]

                                'module-build-macros', '1.0', "1.{0}".format(dist_tag), 4, None)

          assert component_build.state == koji.BUILD_STATES["COMPLETE"]

      def test_route_components_build_task_finalize_task(self, send_task_message):

          scheduler_init_data()

          components.build_task_finalize.delay(

          queue = send_task_message.call_args[1].get("queue")

          qname = queue.__dict__.get("name")

          assert qname == "mbs-2"

      def test_route_components_build_task_finalize_task_without_a_module(self, send_task_message):

          scheduler_init_data()

          components.build_task_finalize.delay(

          queue = send_task_message.call_args[1].get("queue")

          qname = queue.__dict__.get("name")

          assert qname == "mbs-default"

          scheduler_init_data()

          tags.tagged.delay(

              "fakemsg", "module-testmodule-master-20170109091357-7c29193d-build",

          queue = send_task_message.call_args[1].get("queue")

          qname = queue.__dict__.get("name")

          assert qname == "mbs-2"

          parser = FedmsgMessageParser(messaging.known_fedmsg_services)

          event_info = parser.parse(buildsys_state_change_msg)

          assert event_info["build_new_state"] == 1

      def test_buildsys_tag(self):

          event_info = parser.parse(buildsys_tag_msg)

          assert event_info["tag_name"] == "module-debugging-tools-master-20170405115403-build"

      def test_buildsys_repo_done(self):

          # https://fedora-fedmsg.readthedocs.io/en/latest/topics.html#id134

          assert event_info["event"] == events.KOJI_TAG_CHANGE

          assert event_info["msg_id"] == msg["msg_id"]

          assert event_info["tag_name"] == msg["msg"]["tag"]

      @patch("module_build_service.scheduler.consumer.models")

      @patch.object(MBSConsumer, "process_message")

                      {"id": 1, "name": module_build_2.koji_tag + "-build"})

                  expected_tagged_calls.append(call(

                      "internal:sync_koji_build_tags",

                  ))

              if tagged_in_final:

                  listtags_return_value.append(

                      {"id": 2, "name": module_build_2.koji_tag})

                  expected_tagged_calls.append(call(

                      "internal:sync_koji_build_tags",

                  ))

          koji_session.listTags.return_value = listtags_return_value

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="no matches for this...",

              tag_name="2016-some-nonexistent-build",

              build_nvr="artifact-1.2-1")

      def test_no_matching_artifact(self):

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="artifact-1.2-1",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          # Tag the first component to the final tag.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          # Tag the perl-List-Compare component to final tag.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          # Tag the perl-List-Compare component to final tag.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          # Tag the first component to the final tag.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          # Tag the second component to final tag.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="module-build-macros-0.1-1.module+0+b0a1d1f7",

          )

          # Tag the component from first batch to the buildroot.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="module-build-macros-0.1-1.module+0+b0a1d1f7",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          assert not koji_session.newRepo.called

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          # Tag the perl-List-Compare component to final tag.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          # Tag the first component to the final tag.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-Tangerine-0.23-1.module+0+d027b723",

          )

          # Tag the second component to the buildroot.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c-build",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          # Tag the second component to the final tag.

          module_build_service.scheduler.handlers.tags.tagged(

              msg_id="id",

              tag_name="module-testmodule-master-20170219191323-c40c156c",

              build_nvr="perl-List-Compare-0.53-5.module+0+d027b723",

          )

          for event in events.scheduler.queue:

              event_info = event[3]

              if event_info[0].startswith("reuse_component"):

                  component_build = models.ComponentBuild.from_component_event(

                      db_session,

                  assert component_build.state == koji.BUILD_STATES["BUILDING"]

          # When we handle these KojiBuildChange messages, MBS should tag all

          # to BUILDING, so KojiBuildChange message handler handles the change

          # properly.

          event_info = events.scheduler.queue[0][3]

                                '0.23', '1.module+0+d027b723', 3,

                                'Reused component from previous module build')

          component_build = models.ComponentBuild.from_component_event(

              db_session,

          )

          assert component_build.state == koji.BUILD_STATES["BUILDING"]

          assert component_build.package == "perl-Tangerine"

          # in the DB should be set to BUILDING, so the build state change handler

          # handles the change properly.

          event_info = events.scheduler.queue[0][3]

                                'perl-Tangerine', '0.23', '1.module+0+d027b723', 3,

                                'Reused component from previous module build')

          component_build = models.ComponentBuild.from_component_event(

              db_session,

          )

          assert component_build.state == koji.BUILD_STATES["BUILDING"]

          assert component_build.package == "perl-Tangerine"

          # Verify that tangerine was reused even though perl-Tangerine was rebuilt in the previous

          # batch

          event_info = events.scheduler.queue[0][3]

                                '3.module+0+d027b723', 3,

                                'Reused component from previous module build')

          component_build = models.ComponentBuild.from_component_event(

              db_session,

          )

          assert component_build.state == koji.BUILD_STATES["BUILDING"]

          assert component_build.package == "tangerine"