From 3c885bec3b51b35c77c983444a949783cb53e198 Mon Sep 17 00:00:00 2001 From: Azka Nathan Date: Tue, 6 Jan 2026 13:01:13 +0700 Subject: queuing job --- fixco_custom/models/queue_job.py | 46 ++++++++++++++++++++++++++++++++++++++++ 1 file changed, 46 insertions(+) create mode 100644 fixco_custom/models/queue_job.py (limited to 'fixco_custom/models/queue_job.py') diff --git a/fixco_custom/models/queue_job.py b/fixco_custom/models/queue_job.py new file mode 100644 index 0000000..68ddf8c --- /dev/null +++ b/fixco_custom/models/queue_job.py @@ -0,0 +1,46 @@ +from odoo import models, fields, api +from odoo.exceptions import UserError +import traceback + +class QueueJob(models.Model): + _name = 'queue.job' + _description = 'Queueing Job Runner' + _order = 'create_date desc' + + name = fields.Char(required=True) + model_name = fields.Char(required=True) + method_name = fields.Char(required=True) + res_id = fields.Integer(string='Record ID') + state = fields.Selection([ + ('draft', 'Draft'), + ('running', 'Running'), + ('done', 'Done'), + ('error', 'Error'), + ], default='draft') + + error_message = fields.Text() + + def action_run_selected(self): + for job in self: + job.action_run() + + def action_run(self, limit=10): + jobs = self.search([('state', '=', 'draft')], order='create_date desc', limit=limit) + for job in jobs: + job.state = 'running' + try: + + record = self.env[job.model_name].browse(job.res_id) + if not record.exists(): + raise UserError('Target record not found') + + method = getattr(record, job.method_name, None) + if not method: + raise UserError('Method not found') + + method() # 🔥 EXECUTE + job.state = 'done' + + except Exception as e: + job.state = 'error' + job.error_message = traceback.format_exc() -- cgit v1.2.3 From 768525ae58075760bf2179eadefbe5277acbd1ab Mon Sep 17 00:00:00 2001 From: Azka Nathan Date: Tue, 6 Jan 2026 13:57:24 +0700 Subject: push --- fixco_custom/models/queue_job.py | 24 +++++++++++++++++------- 1 file changed, 17 insertions(+), 7 deletions(-) (limited to 'fixco_custom/models/queue_job.py') diff --git a/fixco_custom/models/queue_job.py b/fixco_custom/models/queue_job.py index 68ddf8c..56926e3 100644 --- a/fixco_custom/models/queue_job.py +++ b/fixco_custom/models/queue_job.py @@ -25,10 +25,13 @@ class QueueJob(models.Model): job.action_run() def action_run(self, limit=10): - jobs = self.search([('state', '=', 'draft')], order='create_date desc', limit=limit) + jobs = self.search([('state', '=', 'draft'), ('method_name', '=', 'get_order_id_and_create_detail_order')], order='create_date desc', limit=limit) + if not jobs: + jobs = self.search([('state', '=', 'draft'), ('method_name', '!=', 'get_order_id_and_create_detail_order')], order='create_date desc', limit=limit) for job in jobs: - job.state = 'running' try: + job.write({'state': 'running'}) + self.env.cr.commit() record = self.env[job.model_name].browse(job.res_id) if not record.exists(): @@ -38,9 +41,16 @@ class QueueJob(models.Model): if not method: raise UserError('Method not found') - method() # 🔥 EXECUTE - job.state = 'done' + with self.env.cr.savepoint(): + method() + + job.write({'state': 'done'}) + self.env.cr.commit() + + except Exception: + job.write({ + 'state': 'error', + 'error_message': traceback.format_exc() + }) + self.env.cr.commit() - except Exception as e: - job.state = 'error' - job.error_message = traceback.format_exc() -- cgit v1.2.3