Add ddmrp_cron_actions_as_job

It makes every calls to "cron_actions" run in queue jobs.

The jobs have an identity key with "identity_exact", meaning that only
one occurence of a job for the same buffer with the same arguments
(only_nfp) will be created at a time (e.g. when the state of a
stock.move is changed several times in the same transaction or in
a different transaction in a short timeframe).

It needs OCA/queue#274 and
OCA/queue#275

Author: guewen

ddmrp/tests/common.py

@@ -12,6 +12,16 @@ class TestDdmrpCommon(common.SavepointCase):
     def setUpClass(cls):
         super().setUpClass()
 
+        cls.env = cls.env(
+            context=dict(
+                cls.env.context,
+                tracking_disable=True,
+                # compatibility with ddmrp_cron_actions_as_job,
+                # that would delay calls to "cron_actions" in these tests
+                test_queue_job_no_delay=True,
+            )
+        )
+
         # Models
         cls.productModel = cls.env["product.product"]
         cls.templateModel = cls.env["product.template"]

ddmrp_cron_actions_as_job/__init__.py

@@ -0,0 +1 @@
+from . import models

ddmrp_cron_actions_as_job/__manifest__.py

@@ -0,0 +1,15 @@
+# Copyright 2020 Camptocamp (https://www.camptocamp.com)
+# License LGPL-3.0 or later (https://www.gnu.org/licenses/lgpl.html).
+
+{
+    "name": "DDMRP Buffer Calculation as job",
+    "version": "13.0.1.0.0",
+    "summary": "Run DDMRP Buffer Calculation as jobs",
+    "author": "Camptocamp, Odoo Community Association (OCA)",
+    "website": "https://github.com/OCA/ddmrp",
+    "category": "Warehouse Management",
+    "depends": ["ddmrp", "queue_job"],
+    "data": ["data/queue_job_channel_data.xml", "data/queue_job_function_data.xml"],
+    "license": "LGPL-3",
+    "installable": True,
+}

ddmrp_cron_actions_as_job/data/queue_job_channel_data.xml

@@ -0,0 +1,6 @@
+<odoo noupdate="1">
+    <record model="queue.job.channel" id="channel_ddmrp">
+        <field name="name">ddmrp</field>
+        <field name="parent_id" ref="queue_job.channel_root" />
+    </record>
+</odoo>

ddmrp_cron_actions_as_job/data/queue_job_function_data.xml

@@ -0,0 +1,6 @@
+<odoo noupdate="1">
+    <record id="job_function_stock_buffer_cron_actions" model="queue.job.function">
+        <field name="name"><![CDATA[<stock.buffer>.cron_actions]]></field>
+        <field name="channel_id" ref="channel_ddmrp" />
+    </record>
+</odoo>

ddmrp_cron_actions_as_job/models/__init__.py

@@ -0,0 +1 @@
+from . import stock_buffer

ddmrp_cron_actions_as_job/models/stock_buffer.py

@@ -0,0 +1,21 @@
+# Copyright 2020 Camptocamp (https://www.camptocamp.com)
+# License LGPL-3.0 or later (https://www.gnu.org/licenses/lgpl.html).
+
+from odoo import models
+
+from odoo.addons.queue_job.job import identity_exact
+
+
+class Buffer(models.Model):
+    _inherit = "stock.buffer"
+
+    def cron_actions_job_options(self, only_nfp=False):
+        return {
+            "identity_key": identity_exact,
+            "priority": 15,
+            "description": "DDMRP Buffer calculation ({})".format(self.display_name),
+        }
+
+    def _register_hook(self):
+        self._patch_method("cron_actions", self._patch_job_auto_delay("cron_actions"))
+        return super()._register_hook()

ddmrp_cron_actions_as_job/readme/CONTRIBUTORS.rst

@@ -0,0 +1 @@
+* Guewen Baconnier <guewen.baconnier@camptocamp.com>

ddmrp_cron_actions_as_job/readme/DESCRIPTION.rst

@@ -0,0 +1,5 @@
+DDMRP Buffer calculations are now run with Queue Jobs.
+
+When auto-update of NFP is active, each time the state of a stock move changes,
+a new computation is triggered, but thanks to identity keys on jobs, only one
+job at a time is generated for the same buffer.

ddmrp_cron_actions_as_job/tests/__init__.py

@@ -0,0 +1 @@
+from . import test_cron_actions_as_job