При попытке запуска функции через delay (celery) выбрасывает ошибку database is closed, помогите разобраться
Я пытаюсь в проекте django, помещенном в docker, при помощи периодической задачи в Celery отослать письмо списку подписчиков , при этом передаю этот список аргументом в функцию через delay, но мне выбрасывает ошибку database is closed, подозреваю, что закрыт доступ к соответствующей таблице в базе, подскажите, что тут не так?

docker-compose.yml
version: "3.9"
services:
django:
build: .
container_name: django
command: python manage.py runserver 0.0.0.0:8000
volumes:
- .:/usr/src/app/
ports:
- "8000:8000"
environment:
- DEBUG=1
- DJANGO_ALLOWED_HOSTS=localhost 127.0.0.1 [::1]
- CELERY_BROKER=redis://redis:6379/0
- CELERY_BACKEND=redis://redis:6379/0
- REDIS_HOST=redis
depends_on:
- redis
redis:
image: "bitnami/redis:latest"
ports:
- 6379:6379
environment:
- ALLOW_EMPTY_PASSWORD=yes
celery:
build: .
command: celery -A bulletinboard worker -l INFO
volumes:
- .:/usr/src/app/
environment:
- DEBUG=1
- DJANGO_ALLOWED_HOSTS=localhost 127.0.0.1 [::1]
- CELERY_BROKER=redis://redis:6379/0
- CELERY_BACKEND=redis://redis:6379/0
depends_on:
- redis
- django
settings.py
BROKER_URL = 'redis://redis'
CELERY_RESULT_BACKEND = 'redis://redis'
CELERY_ACCEPT_CONTENT = ['application/json']
CELERY_TASK_SERIALIZER = 'json'
CELERY_RESULT_SERIALIZER = 'json'
CELERY_TIMEZONE = 'Europe/Kiev'
tasks.py
@shared_task
def send_new_email(subject, message, from_email, recipients_list):
send_mail(subject, message, from_email, recipient_list=recipients_list)
models.py
def send_announce_email(sender, instance, created, **kwargs):
"""
Sending a letter to subscribers on a new announcement
"""
item = instance
if created:
item_info = {
'name': item.name,
'description': item.description,
'seller': item.seller,
'price': item.price
}
message = render_to_string('mails/item_info.html', item_info)
subject = "New Add for You!"
from_email = '[email protected]'
recipients_list = list(Subscriber.objects.values_list('subscriber__email', flat=True))
send_new_email.delay(subject, message, from_email, recipients_list)
post_save.connect(send_announce_email, sender=Item)
post_save.connect(send_announce_email, sender=Service)
post_save.connect(send_announce_email, sender=Auto)