Я использую сельдерей для выполнения sql операторов usng sqlalchemy. У меня есть один выделенный работник для выполнения этого действия. Я установил уровень параллелизма на 1, так как хочу последовательно выполнять все свои операторы. Мало кто из заявлений работает за 5-6 часов. Когда какое-либо задание выполнялось дольше 4900-5000 секунд, мое следующее задание не было обработано работником, даже если этот работник свободен. Мой send_task () возвращает мне идентификатор задачи с ожидающим состоянием, но работник не выбирает эту задачу. Мои настройки сельдерея
app = Celery('tasks', broker=config.AGENT_BROKER,
backend=config.AGENT_BACKEND, include=['tasks'],
task_serializer='json')
Моя команда запуска сельдерея
celery -A tasks worker -c 1 -Q executesql -P eventlet
Пожалуйста, помогите