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

Top-level error handling.

Browse Source
This commit is contained in:
Ralph Bean
2016-07-16 01:02:16 -04:00
parent dee31ed512
commit 285cf212c1
1 changed files with 21 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
rida/scheduler/main.py
View File

@@ -113,23 +113,29 @@ class Messaging(threading.Thread):
self.sanity_check()
for msg in rida.messaging.listen(backend=config.messaging):
log.debug("received %r, %r" % (msg['msg_id'], msg['topic']))
try:
self.process_message(msg)
except Exception:
log.exception("Failed while handling %r" % msg['msg_id'])
# Choose a handler for this message
if '.buildsys.repo.done' in msg['topic']:
handler = self.on_repo_change
elif '.buildsys.build.state.change' in msg['topic']:
handler = self.on_build_change[msg['msg']['new']]
elif '.rida.module.state.change' in msg['topic']:
handler = self.on_module_change[module_build_state_from_msg(msg)]
else:
log.debug("Unhandled message...")
continue
def process_message(self, msg):
log.debug("received %r, %r" % (msg['msg_id'], msg['topic']))
# Execute our chosen handler
with rida.database.Database(config) as session:
log.info(" %r: %s, %s" % (handler, msg['topic'], msg['msg_id']))
handler(config, session, msg)
# Choose a handler for this message
if '.buildsys.repo.done' in msg['topic']:
handler = self.on_repo_change
elif '.buildsys.build.state.change' in msg['topic']:
handler = self.on_build_change[msg['msg']['new']]
elif '.rida.module.state.change' in msg['topic']:
handler = self.on_module_change[module_build_state_from_msg(msg)]
else:
log.debug("Unhandled message...")
return
# Execute our chosen handler
with rida.database.Database(config) as session:
log.info(" %r: %s, %s" % (handler, msg['topic'], msg['msg_id']))
handler(config, session, msg)
class Polling(threading.Thread):
def run(self):