This document describes the current stable version of Celery (5.5). For development docs, go here.

celery.worker.consumer.agent

Celery + https://pypi.org/project/cell/ integration.

class celery.worker.consumer.agent.Agent(c, **kwargs)[source]

Agent starts https://pypi.org/project/cell/ actors.

conditional = True
create(c)[source]

Create the step.

name = 'celery.worker.consumer.agent.Agent'
requires = (step:celery.worker.consumer.connection.Connection{()},)