Samir Boulahtit
f20266167d
- Auto-fixed 4,496 lint issues (import sorting, modern syntax, etc.) - Added ignore rules for patterns intentional in this codebase: E402 (late imports), E712 (SQLAlchemy filters), B904 (raise from), SIM108/SIM105/SIM117 (readability preferences) - Added per-file ignores for tests and scripts - Excluded broken scripts/rename_terminology.py (has curly quotes) Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
20 lines
662 B
Python
20 lines
662 B
Python
# app/tasks/__init__.py
|
|
"""
|
|
Task dispatcher for Celery background tasks.
|
|
|
|
All Celery tasks are defined in their respective modules:
|
|
- app.modules.marketplace.tasks: Import/export/sync tasks
|
|
- app.modules.billing.tasks: Subscription management tasks
|
|
- app.modules.dev_tools.tasks: Code quality and test runner tasks
|
|
- app.modules.monitoring.tasks: Capacity monitoring tasks
|
|
|
|
Use the task_dispatcher for dispatching tasks from API routes:
|
|
from app.tasks import task_dispatcher
|
|
|
|
task_id = task_dispatcher.dispatch_marketplace_import(...)
|
|
"""
|
|
|
|
from app.tasks.dispatcher import TaskDispatcher, task_dispatcher
|
|
|
|
__all__ = ["task_dispatcher", "TaskDispatcher"]
|