Set koji fedmsg plugin to use the new postCommit hook.
https://pagure.io/fedora-infrastructure/issue/5546
This commit is contained in:
parent
fa1fbf2634
commit
3ec2515f09
1 changed files with 0 additions and 5 deletions
|
@ -179,10 +179,6 @@ def queue_message(cbtype, *args, **kws):
|
||||||
|
|
||||||
body = scrub(body)
|
body = scrub(body)
|
||||||
|
|
||||||
{% if env != 'staging' %}
|
|
||||||
# Send the messages immediately.
|
|
||||||
fedmsg.publish(topic=topic, msg=body, modname='buildsys')
|
|
||||||
{% else %}
|
|
||||||
# Queue the message for later.
|
# Queue the message for later.
|
||||||
# It will only get sent after postCommit is called.
|
# It will only get sent after postCommit is called.
|
||||||
messages = getattr(context, 'fedmsg_plugin_messages', [])
|
messages = getattr(context, 'fedmsg_plugin_messages', [])
|
||||||
|
@ -197,4 +193,3 @@ def send_messages(cbtype, *args, **kws):
|
||||||
messages = getattr(context, 'fedmsg_plugin_messages', [])
|
messages = getattr(context, 'fedmsg_plugin_messages', [])
|
||||||
for message in messages:
|
for message in messages:
|
||||||
fedmsg.publish(**message)
|
fedmsg.publish(**message)
|
||||||
{% endif %}
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue