Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ Available addons
addon | version | maintainers | summary
--- | --- | --- | ---
[base_import_async](base_import_async/) | 18.0.1.0.0 | | Import CSV files in the background
[queue_job](queue_job/) | 18.0.1.6.1 | <a href='https://github.com/guewen'><img src='https://github.com/guewen.png' width='32' height='32' style='border-radius:50%;' alt='guewen'/></a> | Job Queue
[queue_job](queue_job/) | 18.0.1.7.0 | <a href='https://github.com/guewen'><img src='https://github.com/guewen.png' width='32' height='32' style='border-radius:50%;' alt='guewen'/></a> | Job Queue
[queue_job_batch](queue_job_batch/) | 18.0.1.0.0 | | Job Queue Batch
[queue_job_cron](queue_job_cron/) | 18.0.1.1.1 | | Scheduled Actions as Queue Jobs
[queue_job_cron_jobrunner](queue_job_cron_jobrunner/) | 18.0.1.0.0 | <a href='https://github.com/ivantodorovich'><img src='https://github.com/ivantodorovich.png' width='32' height='32' style='border-radius:50%;' alt='ivantodorovich'/></a> | Run jobs without a dedicated JobRunner
Expand Down
2 changes: 1 addition & 1 deletion queue_job/README.rst
Original file line number Diff line number Diff line change
Expand Up @@ -11,7 +11,7 @@ Job Queue
!! This file is generated by oca-gen-addon-readme !!
!! changes will be overwritten. !!
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
!! source digest: sha256:466f6aa00ff9f233be68be1eb6a109af5048ea856cc3c0086a7b479b32c83f00
!! source digest: sha256:1546ea44a63ecafe2dcee75567a04b4df20b00c51c1494a42056b388ddec15ad
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!

.. |badge1| image:: https://img.shields.io/badge/maturity-Mature-brightgreen.png
Expand Down
2 changes: 1 addition & 1 deletion queue_job/__manifest__.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@

{
"name": "Job Queue",
"version": "18.0.1.6.1",
"version": "18.0.1.7.0",
"author": "Camptocamp,ACSONE SA/NV,Odoo Community Association (OCA)",
"website": "https://github.com/OCA/queue",
"license": "LGPL-3",
Expand Down
9 changes: 3 additions & 6 deletions queue_job/i18n/de.po
Original file line number Diff line number Diff line change
Expand Up @@ -390,7 +390,6 @@ msgstr ""

#. module: queue_job
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_error
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr ""
"Wenn das Häkchen gesetzt ist, gibt es einige Nachrichten mit einem "
Expand Down Expand Up @@ -748,11 +747,6 @@ msgstr ""
msgid "Retry Pattern (serialized)"
msgstr ""

#. module: queue_job
#: model:ir.model.fields,field_description:queue_job.field_queue_job__message_has_sms_error
msgid "SMS Delivery error"
msgstr "Fehler bei der SMS Nachrichtenübermittlung"

#. module: queue_job
#: model:ir.model,name:queue_job.model_queue_jobs_to_done
msgid "Set all selected jobs to done"
Expand Down Expand Up @@ -929,6 +923,9 @@ msgstr "Assistent zur erneuten Einreihung einer Job-Auswahl"
msgid "Worker Pid"
msgstr ""

#~ msgid "SMS Delivery error"
#~ msgstr "Fehler bei der SMS Nachrichtenübermittlung"

#, python-format
#~ msgid "Job interrupted and set to Done: nothing to do."
#~ msgstr "Job unterbrochen und als Erledigt markiert: Es ist nicht zu tun."
Expand Down
9 changes: 3 additions & 6 deletions queue_job/i18n/es.po
Original file line number Diff line number Diff line change
Expand Up @@ -395,7 +395,6 @@ msgstr ""

#. module: queue_job
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_error
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr "Si se encuentra seleccionado, algunos mensajes tienen error de envío."

Expand Down Expand Up @@ -756,11 +755,6 @@ msgstr "Patrón de reintentos"
msgid "Retry Pattern (serialized)"
msgstr "Patrón de reintentos (en serie)"

#. module: queue_job
#: model:ir.model.fields,field_description:queue_job.field_queue_job__message_has_sms_error
msgid "SMS Delivery error"
msgstr "Error de entrega del SMS"

#. module: queue_job
#: model:ir.model,name:queue_job.model_queue_jobs_to_done
msgid "Set all selected jobs to done"
Expand Down Expand Up @@ -947,6 +941,9 @@ msgstr "Asistente para volver a poner en cola una selección de trabajos"
msgid "Worker Pid"
msgstr "Pid del trabajador"

#~ msgid "SMS Delivery error"
#~ msgstr "Error de entrega del SMS"

#, python-format
#~ msgid "Cancelled by %s"
#~ msgstr "Cancelado por %s"
Expand Down
9 changes: 3 additions & 6 deletions queue_job/i18n/it.po
Original file line number Diff line number Diff line change
Expand Up @@ -392,7 +392,6 @@ msgstr "Se selezionata, nuovi messaggi richiedono attenzione."

#. module: queue_job
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_error
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr "Se selezionata, alcuni messaggi hanno un errore di consegna."

Expand Down Expand Up @@ -753,11 +752,6 @@ msgstr "Riprova schema"
msgid "Retry Pattern (serialized)"
msgstr "Riprova schema (serializzato)"

#. module: queue_job
#: model:ir.model.fields,field_description:queue_job.field_queue_job__message_has_sms_error
msgid "SMS Delivery error"
msgstr "Errore consegna SMS"

#. module: queue_job
#: model:ir.model,name:queue_job.model_queue_jobs_to_done
msgid "Set all selected jobs to done"
Expand Down Expand Up @@ -946,6 +940,9 @@ msgstr "Procedura guidata per riaccodare una selezione di lavori"
msgid "Worker Pid"
msgstr "PID worker"

#~ msgid "SMS Delivery error"
#~ msgstr "Errore consegna SMS"

#, python-format
#~ msgid "Cancelled by %s"
#~ msgstr "Annullata da %s"
Expand Down
6 changes: 0 additions & 6 deletions queue_job/i18n/queue_job.pot
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,6 @@ msgstr ""

#. module: queue_job
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_error
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr ""

Expand Down Expand Up @@ -736,11 +735,6 @@ msgstr ""
msgid "Retry Pattern (serialized)"
msgstr ""

#. module: queue_job
#: model:ir.model.fields,field_description:queue_job.field_queue_job__message_has_sms_error
msgid "SMS Delivery error"
msgstr ""

#. module: queue_job
#: model:ir.model,name:queue_job.model_queue_jobs_to_done
msgid "Set all selected jobs to done"
Expand Down
13 changes: 5 additions & 8 deletions queue_job/i18n/tr.po
Original file line number Diff line number Diff line change
Expand Up @@ -392,7 +392,6 @@ msgstr "İşaretlenirse, sizi bekleyen mesajlar var."

#. module: queue_job
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_error
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr "İşaretlenirse, bazı mesajlar teslimat hatası içerir."

Expand Down Expand Up @@ -753,11 +752,6 @@ msgstr "Deseni Yeniden Dene"
msgid "Retry Pattern (serialized)"
msgstr "Deseni Yeniden Dene (serileştirilmiş)"

#. module: queue_job
#: model:ir.model.fields,field_description:queue_job.field_queue_job__message_has_sms_error
msgid "SMS Delivery error"
msgstr "SMS Teslim hatası"

#. module: queue_job
#: model:ir.model,name:queue_job.model_queue_jobs_to_done
msgid "Set all selected jobs to done"
Expand Down Expand Up @@ -908,8 +902,8 @@ msgid ""
msgstr ""
"{} için Beklenmeyen İlgili Eylem formatı.\n"
"Geçerli format örneği:\n"
"{{\"enable\": True, \"func_name\": \"related_action_foo\", \"kwargs\" {{"
"\"limit\": 10}}}}"
"{{\"enable\": True, \"func_name\": \"related_action_foo\", "
"\"kwargs\" {{\"limit\": 10}}}}"

#. module: queue_job
#. odoo-python
Expand Down Expand Up @@ -945,3 +939,6 @@ msgstr "Seçilen işleri yeniden sıraya almak için sihirbaz"
#: model:ir.model.fields,field_description:queue_job.field_queue_job__worker_pid
msgid "Worker Pid"
msgstr "Çalışan Pid"

#~ msgid "SMS Delivery error"
#~ msgstr "SMS Teslim hatası"
6 changes: 0 additions & 6 deletions queue_job/i18n/tr_TR.po
Original file line number Diff line number Diff line change
Expand Up @@ -387,7 +387,6 @@ msgstr ""

#. module: queue_job
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_error
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr ""

Expand Down Expand Up @@ -741,11 +740,6 @@ msgstr ""
msgid "Retry Pattern (serialized)"
msgstr ""

#. module: queue_job
#: model:ir.model.fields,field_description:queue_job.field_queue_job__message_has_sms_error
msgid "SMS Delivery error"
msgstr ""

#. module: queue_job
#: model:ir.model,name:queue_job.model_queue_jobs_to_done
msgid "Set all selected jobs to done"
Expand Down
9 changes: 3 additions & 6 deletions queue_job/i18n/zh_CN.po
Original file line number Diff line number Diff line change
Expand Up @@ -392,7 +392,6 @@ msgstr "确认后, 出现提示消息。"

#. module: queue_job
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_error
#: model:ir.model.fields,help:queue_job.field_queue_job__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr "如果勾选此项, 某些消息将会产生传递错误。"

Expand Down Expand Up @@ -751,11 +750,6 @@ msgstr "重试模式"
msgid "Retry Pattern (serialized)"
msgstr "重试模式(已序列化)"

#. module: queue_job
#: model:ir.model.fields,field_description:queue_job.field_queue_job__message_has_sms_error
msgid "SMS Delivery error"
msgstr "短信传递错误"

#. module: queue_job
#: model:ir.model,name:queue_job.model_queue_jobs_to_done
msgid "Set all selected jobs to done"
Expand Down Expand Up @@ -936,6 +930,9 @@ msgstr "重新排队向导所选的作业"
msgid "Worker Pid"
msgstr "工作进程PID"

#~ msgid "SMS Delivery error"
#~ msgstr "短信传递错误"

#, python-format
#~ msgid "Cancelled by %s"
#~ msgstr "被%s取消"
Expand Down
18 changes: 12 additions & 6 deletions queue_job/models/queue_job.py
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@

from odoo import _, api, exceptions, fields, models
from odoo.osv import expression
from odoo.tools import config, html_escape
from odoo.tools import config, html_escape, index_exists

from odoo.addons.base_sparse_field.models.fields import Serialized

Expand Down Expand Up @@ -128,16 +128,21 @@ class QueueJob(models.Model):
worker_pid = fields.Integer(readonly=True)

def init(self):
self._cr.execute(
"SELECT indexname FROM pg_indexes WHERE indexname = %s ",
("queue_job_identity_key_state_partial_index",),
)
if not self._cr.fetchone():
index_1 = "queue_job_identity_key_state_partial_index"
index_2 = "queue_job_channel_date_done_date_created_index"
if not index_exists(self._cr, index_1):
# Used by Job.job_record_with_same_identity_key
self._cr.execute(
"CREATE INDEX queue_job_identity_key_state_partial_index "
"ON queue_job (identity_key) WHERE state in ('pending', "
"'enqueued', 'wait_dependencies') AND identity_key IS NOT NULL;"
)
if not index_exists(self._cr, index_2):
# Used by <queue.job>.autovacuum
self._cr.execute(
"CREATE INDEX queue_job_channel_date_done_date_created_index "
"ON queue_job (channel, date_done, date_created);"
)

@api.depends("dependencies")
def _compute_dependency_graph(self):
Expand Down Expand Up @@ -399,6 +404,7 @@ def autovacuum(self):
("date_cancelled", "<=", deadline),
("channel", "=", channel.complete_name),
],
order="date_done, date_created",
limit=1000,
)
if jobs:
Expand Down
2 changes: 1 addition & 1 deletion queue_job/static/description/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -372,7 +372,7 @@ <h1>Job Queue</h1>
!! This file is generated by oca-gen-addon-readme !!
!! changes will be overwritten. !!
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
!! source digest: sha256:466f6aa00ff9f233be68be1eb6a109af5048ea856cc3c0086a7b479b32c83f00
!! source digest: sha256:1546ea44a63ecafe2dcee75567a04b4df20b00c51c1494a42056b388ddec15ad
!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! -->
<p><a class="reference external image-reference" href="https://odoo-community.org/page/development-status"><img alt="Mature" src="https://img.shields.io/badge/maturity-Mature-brightgreen.png" /></a> <a class="reference external image-reference" href="http://www.gnu.org/licenses/lgpl-3.0-standalone.html"><img alt="License: LGPL-3" src="https://img.shields.io/badge/license-LGPL--3-blue.png" /></a> <a class="reference external image-reference" href="https://github.com/OCA/queue/tree/18.0/queue_job"><img alt="OCA/queue" src="https://img.shields.io/badge/github-OCA%2Fqueue-lightgray.png?logo=github" /></a> <a class="reference external image-reference" href="https://translation.odoo-community.org/projects/queue-18-0/queue-18-0-queue_job"><img alt="Translate me on Weblate" src="https://img.shields.io/badge/weblate-Translate%20me-F47D42.png" /></a> <a class="reference external image-reference" href="https://runboat.odoo-community.org/builds?repo=OCA/queue&amp;target_branch=18.0"><img alt="Try me on Runboat" src="https://img.shields.io/badge/runboat-Try%20me-875A7B.png" /></a></p>
<p>This addon adds an integrated Job Queue to Odoo.</p>
Expand Down
6 changes: 0 additions & 6 deletions queue_job_batch/i18n/es.po
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,6 @@ msgstr "si está marcada, mensajes nuevos requieren su atención."

#. module: queue_job_batch
#: model:ir.model.fields,help:queue_job_batch.field_queue_job_batch__message_has_error
#: model:ir.model.fields,help:queue_job_batch.field_queue_job_batch__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr "Si está seleccionado, algunos mensajes tienen un error de entrega."

Expand Down Expand Up @@ -304,11 +303,6 @@ msgstr "Cola de Trabajo"
msgid "Responsible User"
msgstr "Usuario Responsable"

#. module: queue_job_batch
#: model:ir.model.fields,field_description:queue_job_batch.field_queue_job_batch__message_has_sms_error
msgid "SMS Delivery error"
msgstr ""

#. module: queue_job_batch
#: model:ir.model.fields,field_description:queue_job_batch.field_queue_job_batch__state
#: model_terms:ir.ui.view,arch_db:queue_job_batch.view_queue_job_batch_search
Expand Down
6 changes: 0 additions & 6 deletions queue_job_batch/i18n/fr.po
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,6 @@ msgstr "Si coché, de nouveaux messages requièrent votre attention."

#. module: queue_job_batch
#: model:ir.model.fields,help:queue_job_batch.field_queue_job_batch__message_has_error
#: model:ir.model.fields,help:queue_job_batch.field_queue_job_batch__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr "Si coché, des messages n'ont pas pu être livré."

Expand Down Expand Up @@ -304,11 +303,6 @@ msgstr "File d'attente des travaux"
msgid "Responsible User"
msgstr "Responsable"

#. module: queue_job_batch
#: model:ir.model.fields,field_description:queue_job_batch.field_queue_job_batch__message_has_sms_error
msgid "SMS Delivery error"
msgstr ""

#. module: queue_job_batch
#: model:ir.model.fields,field_description:queue_job_batch.field_queue_job_batch__state
#: model_terms:ir.ui.view,arch_db:queue_job_batch.view_queue_job_batch_search
Expand Down
9 changes: 3 additions & 6 deletions queue_job_batch/i18n/it.po
Original file line number Diff line number Diff line change
Expand Up @@ -149,7 +149,6 @@ msgstr "Se selezionata, nuovi messaggi richiedono attenzione."

#. module: queue_job_batch
#: model:ir.model.fields,help:queue_job_batch.field_queue_job_batch__message_has_error
#: model:ir.model.fields,help:queue_job_batch.field_queue_job_batch__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr "Se selezionata, alcuni messaggi hanno un errore di consegna."

Expand Down Expand Up @@ -304,11 +303,6 @@ msgstr "Lavoro in coda"
msgid "Responsible User"
msgstr "Utente responsabile"

#. module: queue_job_batch
#: model:ir.model.fields,field_description:queue_job_batch.field_queue_job_batch__message_has_sms_error
msgid "SMS Delivery error"
msgstr "Errore consegna SMS"

#. module: queue_job_batch
#: model:ir.model.fields,field_description:queue_job_batch.field_queue_job_batch__state
#: model_terms:ir.ui.view,arch_db:queue_job_batch.view_queue_job_batch_search
Expand Down Expand Up @@ -357,6 +351,9 @@ msgstr "Utente"
msgid "View all job batches"
msgstr "Vedi tutti i gruppi lavoro"

#~ msgid "SMS Delivery error"
#~ msgstr "Errore consegna SMS"

#~ msgid "Draft"
#~ msgstr "Bozza"

Expand Down
6 changes: 0 additions & 6 deletions queue_job_batch/i18n/queue_job_batch.pot
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,6 @@ msgstr ""

#. module: queue_job_batch
#: model:ir.model.fields,help:queue_job_batch.field_queue_job_batch__message_has_error
#: model:ir.model.fields,help:queue_job_batch.field_queue_job_batch__message_has_sms_error
msgid "If checked, some messages have a delivery error."
msgstr ""

Expand Down Expand Up @@ -301,11 +300,6 @@ msgstr ""
msgid "Responsible User"
msgstr ""

#. module: queue_job_batch
#: model:ir.model.fields,field_description:queue_job_batch.field_queue_job_batch__message_has_sms_error
msgid "SMS Delivery error"
msgstr ""

#. module: queue_job_batch
#: model:ir.model.fields,field_description:queue_job_batch.field_queue_job_batch__state
#: model_terms:ir.ui.view,arch_db:queue_job_batch.view_queue_job_batch_search
Expand Down