Add transactional queue and workers

issue7406
review45461002
This commit is contained in:
Cédric Krier committed 2018-07-27 09:32:28 +02:00
1 parent 20670bdc7d
commit 3872f858bf
1 file changed
+5 -2
+5 -2
View File
@@ -162,6 +162,7 @@ class _TrytondMethod(object):
from trytond.rpc import RPC
from trytond.tools import is_instance_method
from trytond.transaction import Transaction
from trytond.worker import run_task
if self._name in self._object.__rpc__:
rpc = self._object.__rpc__[self._name]
@@ -186,8 +187,10 @@ class _TrytondMethod(object):
else:
result = [rpc.result(meth(i, *args, **kwargs))
for i in inst]
if not rpc.readonly:
transaction.commit()
transaction.commit()
while transaction.tasks:
task_id = transaction.tasks.pop()
run_task(self._config.database_name, task_id)
return result