Celery

Package: celery · 8 nodes · Task queues and background jobs

Define tasks, send them to workers, schedule with crontab, and retrieve results asynchronously.

Node Reference

Node	Type	Inputs	Outputs
Create App	statement	-	App (celery.App)
Task	statement	App (celery.App)	Task (celery.Task)
Send Task	statement	Task (celery.Task), Args (list)	Result (celery.AsyncResult)
Get Result	statement	AsyncResult (celery.AsyncResult)	Value (any)
Schedule	statement	App (celery.App), Task (celery.Task)	-
Crontab	expression	-	Schedule (object)
Task Id	expression	AsyncResult (celery.AsyncResult)	Task ID (str)
Task Status	expression	AsyncResult (celery.AsyncResult)	Status (str)