При попытке запуска функции через 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)

Ответы (0 шт):