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)

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

conditional = True

create(c)

Create the step.

name = 'celery.worker.consumer.agent.Agent'

requires = (step:celery.worker.consumer.connection.Connection{()},)