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

celery.worker.consumer.agent

Celery + cell integration.

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

Agent starts cell actors.

conditional = True

create(c)

Create the step.

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

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