Does it help with production monitoring?

Absolutely. It covers the setup of Flower dashboards, implementation of custom signals for Prometheus/Grafana metrics, and automated health checks for workers and brokers.

What are Celery Canvas workflows?

Canvas is a suite of tools including chains, groups, and chords used to design complex task dependencies, allowing tasks to run sequentially, in parallel, or as part of a synchronized fan-in pattern.

How does it improve error handling?

It implements base task classes that automate exponential backoff, jitter-based retries, and dead-letter queue patterns to ensure system reliability during transient failures.

How does this skill handle priority queuing?

It provides standardized configurations for setting up high, default, and low priority queues, including dynamic routing logic and worker-specific prefetch configurations.

Can I use this for API rate limiting?

Yes, the skill includes patterns for fixed-window rate limits directly on tasks and custom token-bucket implementations for more complex distributed throttling needs.

Advanced Celery Orchestration

Name: Advanced Celery Orchestration
Author: yonatangross

byyonatangross

•

API Development

Implements complex background task patterns, enterprise workflows, and production-grade monitoring for Celery in Python environments.

The Advanced Celery skill equips Claude with specialized knowledge for architecting robust distributed task systems beyond simple background jobs. It provides implementation patterns for complex canvas workflows including chains, groups, and chords, alongside sophisticated priority-based routing for multi-tenant applications. By utilizing this skill, developers can implement granular rate limiting to protect external API quotas and ensure production-readiness through established observability patterns, health checks, and custom task state management.

Key Features

01Multi-tier priority queue management and dynamic task routing

02Production monitoring integration with Flower and custom event signals

03Complex canvas workflows (Chains, Groups, Chords, and Starmaps)

0469 GitHub stars

05Granular per-task and dynamic token-bucket rate limiting

06Standardized base task inheritance for DB sessions and exponential backoff

Use Cases

01Building complex ETL pipelines with sequential and parallel data processing steps

02Orchestrating multi-step order fulfillment systems with external API rate limit constraints

03Implementing tiered service levels with priority routing for premium vs. standard users

What are Skills?·How to Install

Install with 🐟 Skill.Fish

npx skillfish add yonatangross/orchestkit celery-advanced

For use in Claude.ai and ChatGPT

Download Skill