run_celery.py

#!/usr/bin/env python
"""
Запуск Celery Worker для обработки уведомлений
"""
import subprocess
import sys
import os
import django

os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'task_manager.settings')
django.setup()

if __name__ == '__main__':
    print("📊 Запуск Celery Worker...")
    print("Обработка уведомлений и периодических задач...")
    
    # Запускаем Celery worker с настройками для Windows
    subprocess.run([
        sys.executable, '-m', 'celery',
        '-A', 'task_manager', 'worker',
        '--loglevel=info',
        '--pool=solo',  # Используем solo pool для Windows
        '--concurrency=1',
        '--without-gossip',  # Отключаем gossip для Windows
        '--without-mingle',  # Отключаем mingle для Windows
        '--without-heartbeat'  # Отключаем heartbeat для Windows
    ])