particle-os/debian-koji
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

messagebus plugin: avoid duplicate context updates

Browse source
This commit is contained in:
Mike McLean 2017-08-03 16:40:45 -04:00
parent 261224311c
commit 2a6c04635f
1 changed files with 4 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

6
plugins/hub/messagebus.py
View file

@ -236,9 +236,11 @@ def prep_message(cbtype, *args, **kws):
else:
raise PluginError('unsupported exchange type: %s' % exchange_type)
messages = getattr(context, 'messagebus_plugin_messages', [])
messages = getattr(context, 'messagebus_plugin_messages', None)
if messages is None:
messages = []
context.messagebus_plugin_messages = messages
messages.append(message)
context.messagebus_plugin_messages = messages
@callback('postCommit')