celery.bootsteps

Ориентированный ациклический граф повторно используемых компонентов.

classcelery.bootsteps.Blueprint(steps=None, name=None, on_start=None, on_close=None, on_stopped=None)

Чертёж, содержащий шаги запуска, которые можно применять к объектам.

Параметры:

• Sequence[Union[str (steps) – Список шагов.

• Step]] – Список шагов.

• name (str) – Задать явное имя для этого чертежа.

• on_start (Callable) – Необязательный callback, вызываемый после запуска чертежа.

• on_close (Callable) – Необязательный callback, вызываемый перед закрытием чертежа.

• on_stopped (Callable) – Необязательный callback, вызываемый после остановки чертежа.

GraphFormatter

псевдоним StepFormatter

propertyalias

apply(parent, **kwargs)

Применить шаги этого чертежа к объекту.

Будут вызваны методы __init__ и include каждого шага, которым в качестве аргумента будет передан объект:

step = Step(obj)
...
step.include(obj)

Для StartStopStep созданные службы также будут добавлены в атрибут steps объекта.

claim_steps()

close(parent)

connect_with(other)

default_steps={}

human_state()

info(parent)

join(timeout=None)

load_step(step)

name=None

restart(parent, method='stop', description='restarting', propagate=False)

send_all(parent, method, description=None, reverse=True, propagate=True, args=())

start(parent)

started=0

state=None

state_to_name={0: 'initializing', 1: 'running', 2: 'closing', 3: 'terminating'}

stop(parent, close=True, terminate=False)

classcelery.bootsteps.ConsumerStep(parent, **kwargs)

Шаг запуска, запускающий потребителя сообщений.

consumers=None

get_consumers(channel)

name='celery.bootsteps.ConsumerStep'

requires=('celery.worker.consumer:Connection',)

shutdown(c)

start(c)

stop(c)

classcelery.bootsteps.StartStopStep(parent, **kwargs)

Шаг запуска, который необходимо запускать и останавливать в определённом порядке.

close(parent)

include(parent)

name='celery.bootsteps.StartStopStep'

obj=None

start(parent)

stop(parent)

terminate(parent)

classcelery.bootsteps.Step(parent, **kwargs)

Шаг запуска.

Метод __init__() вызывается, когда шаг привязывается к родительскому объекту, и поэтому его можно использовать для инициализации атрибутов родительского объекта во время его создания.

propertyalias

conditional=False

create(parent)

Создать шаг.

enabled=True

include(parent)

include_if(parent)

Вернуть true, если шаг запуска следует включить.

Можно определить этот метод как необязательное условие, которое решает, следует ли создавать данный шаг.

info(obj)

instantiate(name, *args, **kwargs)

label=None

last=False

name='celery.bootsteps.Step'

requires=()