Celery

Put a model-method on the Celery Task Queue

Just Python code to call from an Odoo model

Example

Model and method:

• model: "celery.example"
• method: "schedule_import"

Celery Options:

Shall be provided to kwargs of the call_task method

celery = {
    'queue': 'high.priority',
    'countdown': 5,
    'retry': True,
    'retry_countdown_setting': 'MUL_RETRIES_SECS',
    'retry_countdown_multiply_retries_seconds': 60,
    'retry_policy': {
        'interval_start': 30
    }
}

Calling the task:

self.env["celery.task"].call_task("celery.example", "schedule_import", celery=celery)

Celery Options

All Celery options are optional (not required).

Extra kwargs

Extra kwargs are optional (not required).

Installation and configuration

# celery -A odoo worker --loglevel=info

# celery -A odoo worker --loglevel=info -Q high.priority -n high.priority

Changelog

0.22

• Upon processing task rpc_run_task (method), only update the related record fields (res_model, res_ids) if these have a value set in the method its result.
  This enables the API to store these related record fields upfront, when the task is created.

0.21

• Some security hardening: support inactive Celery User, which refuses regular (web) authentication/login.

0.20

• [FIX] In call_task() the search of celery.task.setting results in Access Denied by ACLs for operation: read, model: celery.task.setting. Solved by calling the celery.task.setting search() with sudo().

0.19

• [FIX] Related record: res_ids (now ListSerialized field).
• Also change kwargs field to sensible class(name): TaskSerialized to KwargsSerialized.

0.18

• Configurable (database) transaction strategy, when the task shall apply (ORM create and send to Celery MQ).
• From now on - by default a task shall apply after commit of the main/caller transaction, instead of immediately in the main/caller transaction.

0.17

• Task scheduling added - being able to schedule tasks in a specified time interval or certain day(s) of the week.
• A new task state - Scheduled, is handled by an Odoo cron job - "Celery: Handle Scheduled Tasks".

0.16

• Configurable celery queues added to task settings.

0.15

• Scheduled (cron) cleanup of tasks - with optionally specifying/overriding: (1) timedelta (days=90, hours, minutes, seconds), (2) states to keep and (3) batch_size=100.
• Create database index for the State Time (state_date) field.

0.14

• Create database index for the Reference field (ref).

0.13

• Get XML-RPC URL from ir.config.parameter (celery.celery_base_url) by Settings.

0.12

• Also support to get the Celery (Odoo) user and password from the odoo.conf file, under section [options] too.

0.11

• Put task into a new state Retrying, right before the Retry starts.

0.10

• Renamed task retry settings: 'MUL_RETR' to 'MUL_RETRIES', 'MUL_RETR_SECS' to 'MUL_RETRIES_SECS'.

0.9

• Hide (Odoo) password in the retry payload used by the MQ broker for XML-RPC authentication. Mentoined in GitHub issue: https://github.com/novacode-nl/odoo-celery/issues/17

0.8

• Fix task retry countdown/interval ignored. For more info see GitHub issue
• Add task retry countdown settings, to increase countdown during retries ('ADD_SECS', 'MUL_RETRY', 'MUL_RETRY_SECS').
• Search view of jammed tasks: (1) Add/show field reference (2) search-view with filters and grouping.
• Track task changes of fields model, method, handle_jammed
• Disable create/copy in the task form-view.

0.7

• Task Reference, which serves:
  • Easier searching for tasks by Reference.
  • Check (ORM query) before call_task() call, to prevent redundant creation of recurring Pending tasks.

0.6

• Settings: to specify when a task (model, method) is Jammed after seconds from Started or Retry (states).
• Jammed Tasks Report: which shows Jammed (not completed) tasks.
• Cron or manually put tasks in "Jammed" state.
• Ability to cancel (Pending or Jammed) tasks, which never completed.
• Track and messaging about state change. Chatter on form view.

0.5

• Routing tasks to specific (named) queues.

0.4

• FIX: Store task state (Started, Retry) before execution.

0.3

• Hide (Odoo) password in payload used by the broker for XML-RPC authentication. Mentoined in GitHub issue: https://github.com/novacode-nl/odoo-celery/issues/4

0.2

• Task state information.

0.1

• Initial version.