你正在阅读 Celery 3.1 的文档。开发版本文档见: 此处.

celery.states

Built-in task states.

Sets

READY_STATES

Set of states meaning the task result is ready (has been executed).

UNREADY_STATES

Set of states meaning the task result is not ready (has not been executed).

EXCEPTION_STATES

Set of states meaning the task returned an exception.

PROPAGATE_STATES

Set of exception states that should propagate exceptions to the user.

ALL_STATES

Set of all possible states.

Misc.

celery.states.PENDING = 'PENDING'

Task state is unknown (assumed pending since you know the id).

celery.states.RECEIVED = 'RECEIVED'

Task was received by a worker.

celery.states.STARTED = 'STARTED'

Task was started by a worker (CELERY_TRACK_STARTED).

celery.states.SUCCESS = 'SUCCESS'

Task succeeded

celery.states.FAILURE = 'FAILURE'

Task failed

celery.states.REVOKED = 'REVOKED'

Task was revoked.

celery.states.RETRY = 'RETRY'

Task is waiting for retry.

celery.states.precedence(state)[源代码]

Get the precedence index for state.

Lower index means higher precedence.

class celery.states.state[源代码]

State is a subclass of str, implementing comparison methods adhering to state precedence rules:

>>> from celery.states import state, PENDING, SUCCESS

>>> state(PENDING) < state(SUCCESS)
True

Any custom state is considered to be lower than FAILURE and SUCCESS, but higher than any of the other built-in states:

>>> state('PROGRESS') > state(STARTED)
True

>>> state('PROGRESS') > state('SUCCESS')
False

上一个主题

celery.loaders.base

下一个主题

celery.contrib.abortable

本页