[ADD] test_queue_job: regression test for args/kwargs rebind in in_temporary_env

Author: deeniiz

test_queue_job/data/queue_job_function_data.xml

@@ -20,6 +20,14 @@
         <field name="method">job_with_retry_pattern__no_zero</field>
         <field name="retry_pattern" eval="{3: 180}" />
     </record>
+    <record
+        id="job_function_test_queue_job_job_commit_with_arg_records"
+        model="queue.job.function"
+    >
+        <field name="model_id" ref="test_queue_job.model_test_queue_job" />
+        <field name="method">job_commit_with_arg_records</field>
+        <field name="allow_commit" eval="True" />
+    </record>
     <record
         id="job_function_test_queue_channel_job_sub_channel"
         model="queue.job.function"

test_queue_job/models/test_models.py

@@ -114,6 +114,15 @@ def job_alter_mutable(self, mutable_arg, mutable_kwarg=None):
         mutable_kwarg["b"] = 2
         return mutable_arg, mutable_kwarg
 
+    def job_commit_with_arg_records(self, record, record_list=None, record_dict=None):
+        if record.env.cr is not self.env.cr:
+            raise AssertionError("record argument cursor was not rebound")
+        if record_list and record_list[0].env.cr is not self.env.cr:
+            raise AssertionError("record list argument cursor was not rebound")
+        if record_dict and record_dict["record"].env.cr is not self.env.cr:
+            raise AssertionError("record dict argument cursor was not rebound")
+        record.env.cr.commit()  # pylint: disable=invalid-commit
+
     def delay_me(self, arg, kwarg=None):
         return arg, kwarg
 

test_queue_job/tests/test_job.py

@@ -8,6 +8,7 @@
 import odoo.tests.common as common
 
 from odoo.addons.queue_job import identity_exact
+from odoo.addons.queue_job.controllers.main import RunJobController
 from odoo.addons.queue_job.delay import DelayableGraph
 from odoo.addons.queue_job.exception import (
     FailedJobError,
@@ -68,6 +69,14 @@ def test_perform_args(self):
         result = test_job.perform()
         self.assertEqual(result, (("o", "k"), {"c": "!"}))
 
+    def test_allow_commit_rebinds_recordsets_in_args(self):
+        record = self.env.user.partner_id
+        job = self.env["test.queue.job"].with_delay().job_commit_with_arg_records(
+            record, [record], {"record": record}
+        )
+        RunJobController._runjob(self.env, job)
+        self.assertEqual(job.state, DONE)
+
     def test_retryable_error(self):
         test_job = Job(self.method, kwargs={"raise_retry": True}, max_retries=3)
         self.assertEqual(test_job.retry, 0)