Show All 39 Lines		39	finally:
40	self.queued_tags = set()	40		self.queued_tags = set()
41	else:	41		else:
42	self.log.debug("Woke up, but there were no messages.")	42		self.log.debug("Woke up, but there were no messages.")
43		43
44	def consume(self, message):	44		def consume(self, message):
45	usable_message = fedmsg.encoding.loads(message.body)	45		usable_message = fedmsg.encoding.loads(message.body)
46		46
47	koji_tag = usable_message['msg']['tag']	47		koji_tag = usable_message['msg']['tag']
		48		release = usable_message['msg']['release']
48		49
49	# we want only pending tags	50		# we want only pending tags
50	if not koji_tag.endswith('pending'):	51		if not koji_tag.endswith('pending'):
51	return	52		return
52		53
		54		# do not schledule jobs for blacklisted releases
		55		if release.endswith(tuple(config.blacklist_releases)):
		56		return
		57
53	if not len(self.queued_tags):	58		if not len(self.queued_tags):
54	self.log.info('setting fuse (%d seconds) for koji_tag %s', config.fuse_delay, koji_tag)	59		self.log.info('setting fuse (%d seconds) for koji_tag %s', config.fuse_delay, koji_tag)
55	elif koji_tag not in self.queued_tags:	60		elif koji_tag not in self.queued_tags:
56	self.log.info('adding koji_tag %s to the fuse queue', koji_tag)	61		self.log.info('adding koji_tag %s to the fuse queue', koji_tag)
57		62
58	self.queued_tags.add(koji_tag)	63		self.queued_tags.add(koji_tag)

testing/test_koji_tag_trigger.py

Show First 20 Lines • Show All 77 Lines • ▼ Show 20 Line(s)		73	def test_delayed_consume_upgradepath(self):
78		78
79	trigger_calls = self.helper.trigger.trigger_job.calls()	79		trigger_calls = self.helper.trigger.trigger_job.calls()
80		80
81	assert len(trigger_calls) == 1	81		assert len(trigger_calls) == 1
82		82
83	assert trigger_calls[0][1] == (ref_tag, koji_tag_msg.ITEM_TYPE, self.ref_tasks[0], self.ref_arch)	83		assert trigger_calls[0][1] == (ref_tag, koji_tag_msg.ITEM_TYPE, self.ref_tasks[0], self.ref_arch)
84		84
85	assert self.helper.queued_tags == set()	85		assert self.helper.queued_tags == set()
		86
		87		def test_consume_blacklisted_release(self):
		88		ref_release = '3.el5'
		89		self._create_msg(self.ref_name, ref_release, self.ref_tag, self.ref_version)
		90
		91		self.helper.consume(self.ref_message)
		92
		93		assert self.helper.queued_tags == set([])

Do not schedule for blacklisted releases in koji_tagClosedPublicActions