odoo11-addon-queue-job

========= Job Queue

.. !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! !! This file is generated by oca-gen-addon-readme !! !! changes will be overwritten. !! !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!

.. |badge1| image:: https://img.shields.io/badge/maturity-Mature-brightgreen.png :target: https://odoo-community.org/page/development-status :alt: Mature .. |badge2| image:: https://img.shields.io/badge/licence-LGPL--3-blue.png :target: http://www.gnu.org/licenses/lgpl-3.0-standalone.html :alt: License: LGPL-3 .. |badge3| image:: https://img.shields.io/badge/github-OCA%2Fqueue-lightgray.png?logo=github :target: https://github.com/OCA/queue/tree/11.0/queue_job :alt: OCA/queue .. |badge4| image:: https://img.shields.io/badge/weblate-Translate%20me-F47D42.png :target: https://translation.odoo-community.org/projects/queue-11-0/queue-11-0-queue_job :alt: Translate me on Weblate .. |badge5| image:: https://img.shields.io/badge/runbot-Try%20me-875A7B.png :target: https://runbot.odoo-community.org/runbot/230/11.0 :alt: Try me on Runbot

|badge1| |badge2| |badge3| |badge4| |badge5|

This addon adds an integrated Job Queue to Odoo.

It allows to postpone method calls executed asynchronously.

Jobs are executed in the background by a Jobrunner, in their own transaction.

Example:

.. code-block:: python

from odoo import models, fields, api from odoo.addons.queue_job.job import job

class MyModel(models.Model): _name = 'my.model'

 @api.multi
 @job
 def my_method(self, a, k=None):
     _logger.info('executed with a: %s and k: %s', a, k)

class MyOtherModel(models.Model): _name = 'my.other.model'

  @api.multi
  def button_do_stuff(self):
      self.env['my.model'].with_delay().my_method('a', k=2)

In the snippet of code above, when we call button_do_stuff, a job capturing the method and arguments will be postponed. It will be executed as soon as the Jobrunner has a free bucket, which can be instantaneous if no other job is running.

Features:

• Views for jobs, jobs are stored in PostgreSQL
• Jobrunner: execute the jobs, highly efficient thanks to PostgreSQL's NOTIFY
• Channels: give a capacity for the root channel and its sub-channels and segregate jobs in them. Allow for instance to restrict heavy jobs to be executed one at a time while little ones are executed 4 at a times.
• Retries: Ability to retry jobs by raising a type of exception
• Retry Pattern: the 3 first tries, retry after 10 seconds, the 5 next tries, retry after 1 minutes, ...
• Job properties: priorities, estimated time of arrival (ETA), custom description, number of retries
• Related Actions: link an action on the job view, such as open the record concerned by the job

Table of contents

.. contents:: :local:

Installation

Be sure to have the requests library.

Configuration

• Using environment variables and command line:

  • Adjust environment variables (optional):

    • ODOO_QUEUE_JOB_CHANNELS=root:4 or any other channels configuration. The default is root:1

    • if xmlrpc_port is not set: ODOO_QUEUE_JOB_PORT=8069

  • Start Odoo with --load=web,queue_job and --workers greater than 1. [1]_

• Using the Odoo configuration file:

.. code-block:: ini

[options] (...) workers = 6 server_wide_modules = web,queue_job

(...) [queue_job] channels = root:2

• Confirm the runner is starting correctly by checking the odoo log file:

.. code-block::

...INFO...queue_job.jobrunner.runner: starting ...INFO...queue_job.jobrunner.runner: initializing database connections ...INFO...queue_job.jobrunner.runner: queue job runner ready for db ...INFO...queue_job.jobrunner.runner: database connections ready

• Create jobs (eg using base_import_async) and observe they start immediately and in parallel.

• Tip: to enable debug logging for the queue job, use --log-handler=odoo.addons.queue_job:DEBUG

.. [1] It works with the threaded Odoo server too, although this way of running Odoo is obviously not for production purposes.

Usage

To use this module, you need to:

#. Go to Job Queue menu

Developers

**Bypass jobs on running Odoo**

When you are developing (ie: connector modules) you might want
to bypass the queue job and run your code immediately.

To do so you can set `TEST_QUEUE_JOB_NO_DELAY=1` in your enviroment.

**Bypass jobs in tests**

When writing tests on job-related methods is always tricky to deal with
delayed recordsets. To make your testing life easier
you can set `test_queue_job_no_delay=True` in the context.

Tip: you can do this at test case level like this

.. code-block:: python

    @classmethod
    def setUpClass(cls):
        super().setUpClass()
        cls.env = cls.env(context=dict(
            cls.env.context,
            test_queue_job_no_delay=True,  # no jobs thanks
        ))

Then all your tests execute the job methods synchronously
without delaying any jobs.

Known issues / Roadmap
======================

* After creating a new database or installing ``queue_job`` on an
  existing database, Odoo must be restarted for the runner to detect it.

* When Odoo shuts down normally, it waits for running jobs to finish.
  However, when the Odoo server crashes or is otherwise force-stopped,
  running jobs are interrupted while the runner has no chance to know
  they have been aborted. In such situations, jobs may remain in
  ``started`` or ``enqueued`` state after the Odoo server is halted.
  Since the runner has no way to know if they are actually running or
  not, and does not know for sure if it is safe to restart the jobs,
  it does not attempt to restart them automatically. Such stale jobs
  therefore fill the running queue and prevent other jobs to start.
  You must therefore requeue them manually, either from the Jobs view,
  or by running the following SQL statement *before starting Odoo*:

.. code-block:: sql

  update queue_job set state='pending' where state in ('started', 'enqueued')

Changelog
=========

.. [ The change log. The goal of this file is to help readers
    understand changes between version. The primary audience is
    end users and integrators. Purely technical changes such as
    code refactoring must not be mentioned here.
    
    This file may contain ONE level of section titles, underlined
    with the ~ (tilde) character. Other section markers are
    forbidden and will likely break the structure of the README.rst
    or other documents where this fragment is included. ]

Next
~~~~

* [IMP] Dont' start the Jobrunner if root channel's capacity
  is explicitly set to 0
* [ADD] Ability to set several jobs to done using an multi-action
  (port of `#59 <https://github.com/OCA/queue/pull/59>`_)
* [REF] Extract a method handling the post of a message when a job is failed,
  allowing to modify this behavior from addons
* [ADD] Default "related action" for jobs, opening a form or list view (when
  the job is linked to respectively one record on several).
  (`#46 <https://github.com/OCA/queue/pull/46>`_)
* [FIX] Error when creating a job channel manually
  (`#96 <https://github.com/OCA/queue/pull/96>`_)

11.0.1.1.0 (2018-05-25)

• [ADD] New neat OCA readme file format (#71 <https://github.com/OCA/queue/pull/71>_)
• [ADD] The Jobrunner will keep the same Web Session and no longer generate a new session per job (#54 <https://github.com/OCA/queue/pull/54>_)
• [ADD] Configurable scheme, host and HTTP authentication (#51 <https://github.com/OCA/queue/pull/51>_)
• [ADD] base_sparse_field does not longer need to be set in --load (#47 <https://github.com/OCA/queue/pull/47>_)
• [FIX] Correct automatic registration of channels and job functions (#69 <https://github.com/OCA/queue/pull/69>_)
• [FIX] Correct compatibility with @property methods (#50 <https://github.com/OCA/queue/pull/50>_ and #69 <https://github.com/OCA/queue/pull/69>__)

Bug Tracker

Bugs are tracked on GitHub Issues <https://github.com/OCA/queue/issues>. In case of trouble, please check there if your issue has already been reported. If you spotted it first, help us smashing it by providing a detailed and welcomed feedback <https://github.com/OCA/queue/issues/new?body=module:%20queue_job%0Aversion:%2011.0%0A%0A**Steps%20to%20reproduce**%0A-%20...%0A%0A**Current%20behavior**%0A%0A**Expected%20behavior**>.

Do not contact contributors directly about support or help with technical issues.

Credits

Authors

* Camptocamp
* ACSONE SA/NV

Contributors

• Guewen Baconnier [e-mail]
• Stéphane Bidoul [e-mail]
• Matthieu Dietrich [e-mail]
• Jos De Graeve [e-mail]
• David Lefever [e-mail]
• Laurent Mignon [e-mail]
• Laetitia Gangloff [e-mail]
• Cédric Pigeon [e-mail]

Maintainers

This module is maintained by the OCA.

.. image:: https://odoo-community.org/logo.png
   :alt: Odoo Community Association
   :target: https://odoo-community.org

OCA, or the Odoo Community Association, is a nonprofit organization whose
mission is to support the collaborative development of Odoo features and
promote its widespread use.

.. |maintainer-guewen| image:: https://github.com/guewen.png?size=40px
    :target: https://github.com/guewen
    :alt: guewen

Current `maintainer <https://odoo-community.org/page/maintainer-role>`__:

|maintainer-guewen| 

This module is part of the `OCA/queue <https://github.com/OCA/queue/tree/11.0/queue_job>`_ project on GitHub.

You are welcome to contribute. To learn how please visit https://odoo-community.org/page/Contribute.