[IMP] base_bg: Improvement in jobs run policy

[joa-adhoc]

No description provided.

[roboadhoc]

[Copilot]

Pull request overview

Este PR mejora la política de ejecución de jobs en background implementando un mecanismo de bloqueo optimista con SELECT FOR UPDATE SKIP LOCKED para permitir que múltiples crons procesen jobs concurrentemente sin conflictos.

Changes:

• Introduce el método _try_lock_job() que usa bloqueo a nivel de base de datos para adquirir jobs de forma segura
• Refactoriza _cron_run_enqueued_jobs() para procesar un solo job por ejecución en lugar de múltiples, eliminando la lógica de distribución manual basada en módulo de IDs
• Implementa auto-disparo recursivo de crons cuando quedan jobs pendientes

[Copilot]

Pull request overview

Copilot reviewed 4 out of 4 changed files in this pull request and generated 8 comments.

Comments suppressed due to low confidence (3)

base_bg/tests/test_bg_job.py:199

• Este test está roto porque la nueva firma de bg_enqueue requiere records como primer argumento posicional, pero aquí se pasa "dummy_priority_method" (el método) como primer argumento. Debe agregarse un recordset antes del método: self.base_bg_model.bg_enqueue(self.env["base.bg"], "dummy_priority_method", ...).

    def test_bg_enqueue_applies_custom_priority(self):
        """bg_enqueue must propagate the provided priority into bg.job."""
        job_name = f"Priority Test Job {uuid4().hex}"
        with patch.object(BaseBg, "_trigger_crons"):
            self.base_bg_model.bg_enqueue(
                "dummy_priority_method",
                name=job_name,
                priority=3,
            )

base_bg/tests/test_bg_job.py:218

• Igual que el comentario anterior, este test está roto porque falta el argumento records como primer parámetro de bg_enqueue. Debe agregarse un recordset válido.

    def test_bg_enqueue_filters_unserializable_context_entries(self):
        """Only JSON-safe context keys should be stored in bg.job."""
        job_name = f"Context Test Job {uuid4().hex}"
        partner = self.env["res.partner"].create({"name": "Context Partner"})
        base_bg_ctx = self.base_bg_model.with_context(
            serializable_flag="ok",
            unserializable_partner=partner,
            unserializable_env=self.env,
        )
        with patch.object(BaseBg, "_trigger_crons"):
            base_bg_ctx.bg_enqueue(
                "dummy_context_method",
                name=job_name,
            )

base_bg/models/base_bg.py:21

• El cambio de firma de bg_enqueue(self, method, *args, **kwargs) a bg_enqueue(self, records, method, threshold, *args, **kwargs) es un cambio que rompe la API pública. La forma en que estaba diseñada antes, bg_enqueue usaba self como los registros a procesar. Ahora requiere pasar records explícitamente, lo que rompe todo código existente que llame a este método. Se debería mantener retrocompatibilidad detectando si el primer argumento es un string (método) o un recordset, o documentar claramente este breaking change en las notas de migración.

    def bg_enqueue(self, records, method: str, threshold: int | None = None, *args, **kwargs) -> tuple[dict, "BgJob"]:

[joa-adhoc]

Seguimos en PR #347 v18