QueueProcessor

Overview

Runs a task body inside one named action context.

Delivery writes to several tables per message and has no request to take a context from, so without this each write would record an event that nothing associates with the rest.

on_failure

Error handler.

This is run by the worker when the task fails.

Arguments: exc (Exception): The exception raised by the task. task_id (str): Unique id of the failed task. args (Tuple): Original arguments for the task that failed. kwargs (Dict): Original keyword arguments for the task that failed. einfo (~billiard.einfo.ExceptionInfo): Exception information.

Returns: None: The return value of this handler is ignored.

Signature

on_failure(self, exc, task_id, args, kwargs, einfo)

Parameters

Name	Type	Required	Description
self		yes
exc		yes
task_id		yes
args		yes
kwargs		yes
einfo		yes

Source

server/vueda/vdq/tasks.py:88

on_retry

Retry handler.

This is run by the worker when the task is to be retried.

Arguments: exc (Exception): The exception sent to :meth:retry. task_id (str): Unique id of the retried task. args (Tuple): Original arguments for the retried task. kwargs (Dict): Original keyword arguments for the retried task. einfo (~billiard.einfo.ExceptionInfo): Exception information.

Returns: None: The return value of this handler is ignored.

Signature

on_retry(self, exc, task_id, args, kwargs, einfo)

Parameters

Name	Type	Required	Description
self		yes
exc		yes
task_id		yes
args		yes
kwargs		yes
einfo		yes

Source

server/vueda/vdq/tasks.py:64

Source

server/vueda/vdq/tasks.py:63