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<any>) | 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) |