фикс селоери
This commit is contained in:
parent
a98c403116
commit
3910079223
@ -21,7 +21,7 @@ def cleanup_orphaned_attachments():
|
||||
|
||||
orphaned = MessageAttachment.objects.filter(
|
||||
message__isnull=True,
|
||||
created_at__lt=cutoff_time
|
||||
uploaded_at__lt=cutoff_time
|
||||
)
|
||||
|
||||
count = orphaned.count()
|
||||
|
||||
@ -1,4 +1,5 @@
|
||||
import os
|
||||
import tempfile
|
||||
from datetime import timedelta
|
||||
from pathlib import Path
|
||||
|
||||
@ -522,6 +523,10 @@ CELERY_TASK_SOFT_TIME_LIMIT = 25 * 60 # Мягкий лимит - 25 минут
|
||||
# Настройки для периодических задач (Celery Beat)
|
||||
CELERY_BEAT_SCHEDULER = 'django_celery_beat.schedulers:DatabaseScheduler'
|
||||
|
||||
# PID файлы для Celery (используем /tmp чтобы не требовать root прав)
|
||||
CELERY_BEAT_PIDFILE = os.path.join(tempfile.gettempdir(), 'celery-beat.pid')
|
||||
CELERYD_PIDFILE = os.path.join(tempfile.gettempdir(), 'celery-worker.pid')
|
||||
|
||||
# Расписание периодических задач
|
||||
CELERY_BEAT_SCHEDULE = {
|
||||
'cleanup-orphaned-attachments': {
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user