Как перезапустить celery с помощью cron

Celery установлен внутри докера. Мне нужно перезагружать его по расписанию. Как я могу это сделать? Необходимо, чтобы выполняемые задачи завершили свою работу. Или как заставить команду stop для службы контейнера docker ждать завершения работы celery вот так:

app.conf.beat_schedule = {
    'celery_restart': {
        'task': 'app.tasks.celery_restart',
        'schedule': crontab(hour=2)
    }
}

мой docker-compose.yaml

services:
  back:
    ...
    ...

  celery:
    container_name: my_celery
    restart: always
    command: celery -A core worker -P threads -B -l info -c 100

требования:

django==4.1
celery==5.2.7

Я не могу использовать systemctl и изменить структуру проекта

Вернуться на верх