Use bodhi_id instead of bodhi_update to match libtaskotron
ClosedPublic
Actions

Authored by mkrizek on Apr 15 2014, 3:51 PM.

Details

Reviewers

tflink

Maniphest Tasks

Commits

Summary

Fixes T130

Test Plan

None

Lint

Lint Skipped

Unit

Unit Tests Skipped

Looks good to me. Please merge into develop

Closed by commit rTRGR33bb18a9d512 (authored by @mkrizek).

			Path
M			jobtriggers/bodhi_msg.py (2 lines)
M			jobtriggers/triggers.py (2 lines)

Diff	ID	Base	Description	Created	Lint	Unit
Base			Base
Diff 1	156	95dd97b		Apr 15 2014, 3:51 PM	★	★
Diff 2	157	95dd97b	Commit rTRGR33bb18a9d512ec70b5634f7b8b93ae973f8e8dc9	Apr 15 2014, 3:56 PM	★	★

Commit	Tree	Parents	Author	Summary	Date
79b80522b654	b5eec4b81436	18ccf8510da0	Martin Krizek	Add requirements.txt	Apr 15 2014, 3:49 PM
18ccf8510da0	fe6789af632c	95dd97bc0139	Martin Krizek	Use bodhi_id instead of bodhi_update to match libtaskotron (Show More…)	Apr 15 2014, 3:48 PM

1	import logging	1	import logging
2	import fedmsg	2	import fedmsg
3	import fedmsg.encoding	3	import fedmsg.encoding
4	import fedmsg.consumers	4	import fedmsg.consumers
5		5
6	from . import triggers, utils, config	6	from . import triggers, utils, config
7		7
8		8
9	UNIT_TYPE = 'bodhi_update'	9	UNIT_TYPE = 'bodhi_id'
10		10
11	logging.basicConfig()	11	logging.basicConfig()
12	log = logging.getLogger(__name__)	12	log = logging.getLogger(__name__)
13		13
14		14
15	class BodhiJobTrigger(fedmsg.consumers.FedmsgConsumer):	15	class BodhiJobTrigger(fedmsg.consumers.FedmsgConsumer):
16	topic = "org.fedoraproject.prod.bodhi.update.request.*"	16	topic = "org.fedoraproject.prod.bodhi.update.request.*"
17	jsonify = False	17	jsonify = False
Show All 24 Lines

1	import pprint	1	import pprint
2	import requests	2	import requests
3		3
4	from . import config	4	from . import config
5		5
6	class BaseTrigger(object):	6	class BaseTrigger(object):
7	"""	7	"""
8	Format:	8	Format:
9	{	9	{
10	'item': <name of item - envr, update id, koji tag, etc.>,	10	'item': <name of item - envr, update id, koji tag, etc.>,
11	'item_type': <koji_build, koji_tag, bodhi_update>,	11	'item_type': <koji_build, koji_tag, bodhi_id>,
12	'taskname': <task to be scheduled>,	12	'taskname': <task to be scheduled>,
13	'arch': <arch needed for execution, x86_64, i386 etc.>	13	'arch': <arch needed for execution, x86_64, i386 etc.>
14	}	14	}
15	"""	15	"""
16	def trigger_job(self, item, item_type, taskname, arch):	16	def trigger_job(self, item, item_type, taskname, arch):
17	raise NotImplementedError	17	raise NotImplementedError
18		18
19		19
▲ Show 20 Lines • Show All 52 Lines • Show Last 20 Lines