modules/fm-orchestrator
1
0
Fork 0
mirror of https://pagure.io/fm-orchestrator.git synced 2026-04-04 11:20:00 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

No need for the extra loop here.

Browse Source
This commit is contained in:
Ralph Bean
2016-07-13 12:56:29 -04:00
parent 5563886c07
commit b5bd9d4cb1
1 changed files with 16 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
ridad.py
View File

@@ -48,22 +48,22 @@ config = rida.config.from_file("rida.conf")
class Messaging(threading.Thread):
def run(self):
while True:
# TODO: Listen for bus messages from rida about module builds
# entering the wait state
# TODO: Listen for bus messages from the buildsystem about
# component builds changing state
# TODO: Check for modules that can be set to done/failed
# TODO: Act on these things somehow
# TODO: Emit messages about doing so
for msg in rida.messaging.listen(backend=config.messaging):
print("Saw %r with %r" % (msg['topic'], msg))
if '.buildsys.build.state.change' in msg['topic']:
print("A build changed state in koji!!")
elif '.rida.module.state.change' in msg['topic']:
print("Our frontend says that a module changed state!!")
else:
pass
# TODO: Listen for bus messages from rida about module builds
# entering the wait state
# TODO: Listen for bus messages from the buildsystem about
# component builds changing state
# TODO: Check for modules that can be set to done/failed
# TODO: Act on these things somehow
# TODO: Emit messages about doing so
for msg in rida.messaging.listen(backend=config.messaging):
log.debug("Saw %r, %r" % (msg['msg_id'], msg['topic']))
if '.buildsys.build.state.change' in msg['topic']:
log.info("A build changed state in koji!!")
elif '.rida.module.state.change' in msg['topic']:
log.info("Our frontend says that a module changed state!!")
else:
pass
class Polling(threading.Thread):
def run(self):