Lubuntu/britney2-ubuntu
8
0
Fork 0
mirror of https://git.launchpad.net/~ubuntu-release/britney/+git/britney2-ubuntu synced 2025-06-05 14:51:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

autopkgtest: Publish AMQP messages persistently

Browse Source 
We want to ask the broker to write them out to disk, hoepfully
mitigating against it crashing.
This commit is contained in:
Iain Lane 2018-12-06 09:35:39 +00:00
parent 9f91c536be
commit 62ca3b16b9
No known key found for this signature in database
GPG Key ID: E352D5C51C5041D4
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
britney2/policies/autopkgtest.py
View File

@ -612,7 +612,9 @@ class AutopkgtestPolicy(BasePolicy):
params = json.dumps(params) params = json.dumps(params)
if self.amqp_channel: if self.amqp_channel:
self.amqp_channel.basic_publish(amqp.Message(src + '\n' + params), routing_key=qname) self.amqp_channel.basic_publish(amqp.Message(src + '\n' + params),
routing_key=qname,
delivery_mode=2) # persistent
else: else:
assert self.amqp_file assert self.amqp_file
with open(self.amqp_file, 'a') as f: with open(self.amqp_file, 'a') as f: