Perform job before result assertions in test_record_importer.py

OCA · Oct 4, 2024 · 919db00 · 919db00
1 parent d244118
commit 919db00
Showing 1 changed file with 10 additions and 5 deletions.
diff --git a/connector_importer/tests/test_record_importer.py b/connector_importer/tests/test_record_importer.py
@@ -43,7 +43,8 @@ def test_importer_create(self):
             model: {"created": 10, "errored": 0, "updated": 0, "skipped": 0},
         }
         delayable = res[model]
-        self.assertEqual(delayable.result, expected[model])
+        job_result = delayable.perform()
+        self.assertEqual(job_result, expected[model])
         for k, v in expected[model].items():
             self.assertEqual(len(report[model][k]), v)
         self.assertEqual(self.env[model].search_count([("ref", "like", "id_%")]), 10)
@@ -62,7 +63,8 @@ def test_importer_skip(self):
         model = "res.partner"
         expected = {model: {"created": 8, "errored": 0, "updated": 0, "skipped": 2}}
         delayable = res[model]
-        self.assertEqual(delayable.result, expected[model])
+        job_result = delayable.perform()
+        self.assertEqual(job_result, expected[model])
         for k, v in expected[model].items():
             self.assertEqual(len(report[model][k]), v)
         skipped_msg1 = report[model]["skipped"][0]["message"]
@@ -83,7 +85,8 @@ def test_importer_update(self):
         model = "res.partner"
         expected = {model: {"created": 10, "errored": 0, "updated": 0, "skipped": 0}}
         delayable = res[model]
-        self.assertEqual(delayable.result, expected[model])
+        job_result = delayable.perform()
+        self.assertEqual(job_result, expected[model])
         for k, v in expected[model].items():
             self.assertEqual(len(report[model][k]), v)
         # now run it a second time
@@ -94,7 +97,8 @@ def test_importer_update(self):
         report = self.recordset.get_report()
         expected = {model: {"created": 0, "errored": 0, "updated": 10, "skipped": 0}}
         delayable = res[model]
-        self.assertEqual(delayable.result, expected[model])
+        job_result = delayable.perform()
+        self.assertEqual(job_result, expected[model])
         for k, v in expected[model].items():
             self.assertEqual(len(report[model][k]), v)
         # now run it a second time
@@ -105,7 +109,8 @@ def test_importer_update(self):
         report = self.recordset.get_report()
         expected = {model: {"created": 0, "errored": 0, "updated": 0, "skipped": 10}}
         delayable = res[model]
-        self.assertEqual(delayable.result, expected[model])
+        job_result = delayable.perform()
+        self.assertEqual(job_result, expected[model])
         for k, v in expected[model].items():
             self.assertEqual(len(report[model][k]), v)
         skipped_msg1 = report[model]["skipped"][0]["message"]