celery-task-specialist

What problem does it solve?

This Skill helps developers build robust Celery tasks that perform asynchronous database operations inside gevent-powered workers without running into event loop conflicts or resource leaks.

Core Features & Use Cases

• Enforce the _run_async() helper pattern for all async Celery tasks to ensure correct event loop handling in gevent-based workers.
• Support multi-database task patterns (MariaDB, HRIS SQL Server, BioStar MSSQL) with safe disposal of engines.
• Provide execution tracking for APScheduler-triggered tasks, including status updates and error reporting.
• Include robust retry strategies, timeouts, and structured logging for observability.
• Example use case: Synchronize HRIS data into the local MariaDB while handling transient failures gracefully.

Quick Start

• Create a new Celery task that uses the _run_async() wrapper inside the async _execute() function, declare result before the try block, dispose engines in finally, and return the result after finally.