NextERP/runbot
5
0
Fork 0
mirror of https://github.com/odoo/runbot.git synced 2025-03-27 13:25:47 +07:00
Code Issues Actions Packages Projects Releases Wiki Activity

[FIX] forwardport: queue reliability changes

Browse Source 
Previous version would break if _process_item itself committed which
was bad
This commit is contained in:
Xavier Morel 2019-10-11 09:02:50 +02:00
parent 3ce3dd9569
commit bad016b830
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
forwardport/models/forwardport.py
View File

@ -2,8 +2,6 @@
import logging import logging
from contextlib import ExitStack from contextlib import ExitStack
import subprocess
from odoo import fields, models from odoo import fields, models
@ -16,12 +14,13 @@ class Queue:
def _process(self): def _process(self):
for b in self.search([]): for b in self.search([]):
try: try:
with self.env.cr.savepoint(): b._process_item()
b._process_item()
b.unlink() b.unlink()
self.env.cr.commit() self.env.cr.commit()
except Exception: except Exception:
_logger.exception("Error while processing %s, skipping", b) _logger.exception("Error while processing %s, skipping", b)
self.env.cr.rollback()
self.clear_caches()
class BatchQueue(models.Model, Queue): class BatchQueue(models.Model, Queue):
_name = 'forwardport.batches' _name = 'forwardport.batches'