| |
@@ -323,8 +323,13 @@
|
| |
def _send_msgs(urls, msgs, CONFIG):
|
| |
random.shuffle(urls)
|
| |
for url in urls:
|
| |
- container = Container(TimeoutHandler(url, msgs, CONFIG))
|
| |
- container.run()
|
| |
+ try:
|
| |
+ container = Container(TimeoutHandler(url, msgs, CONFIG))
|
| |
+ container.run()
|
| |
+ except Exception as ex:
|
| |
+ # It's ok if we don't send messages for any reason. We'll try again later.
|
| |
+ LOG.debug(f'container setup error ({url}): {ex}')
|
| |
+
|
| |
if msgs:
|
| |
LOG.debug('could not send to %s, %s messages remaining',
|
| |
url, len(msgs))
|
| |
Fixes: https://pagure.io/koji/issue/3327
It looks to me, that on_settled should work correctly also in this case. So 'context.msgs' should be in valid state.