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

celery.worker.consumer.agent

Celery + cell integration.

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

Agent starts cell actors.

conditional = True
create(c)[source]

Create the step.

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