From ac5cbf1682687b1b81aa798bccfeeb1bfbad1dfb Mon Sep 17 00:00:00 2001 From: Mike McLean Date: Oct 05 2017 20:15:23 +0000 Subject: defer messagebus sync --- diff --git a/plugins/hub/messagebus.py b/plugins/hub/messagebus.py index 50ee98a..a561c4b 100644 --- a/plugins/hub/messagebus.py +++ b/plugins/hub/messagebus.py @@ -242,7 +242,7 @@ def send_messages(cbtype, *args, **kws): return sender = get_sender() for message in messages: - sender.send(message, sync=True, timeout=config.getfloat('broker', 'timeout')) + sender.send(message, sync=False, timeout=config.getfloat('broker', 'timeout')) sender.close(timeout=config.getfloat('broker', 'timeout')) # koji should do this for us, but just in case...