Ребят, подскажите, никто не сталкивался с тем что одна и

CeleryApp.conf.broker_transport_options = {'visibility_timeout': ХХХ} - ХХХ целочисленное значение, в секундах, больше, чем самая долгая таска по таймауту. Там суть в том, что когда воркер берет таску, она становится невидимой для других воркеров. Когда время visibility_timeout проходит, а таска еще не выполнена - она становится видна другим воркерам. Они её берут в работу. И получается, что одна и та же таска исполняется несколькими воркерами.

0

25.09.2023

Stanislav Evih Автор вопроса

Anatoly
CeleryApp.conf.broker_transport_options = {'visibi...

Принял спасибо, есть ли минусы установки большого значения для visibility_timeout?

0

25.09.2023

Ded

Stanislav Evih
Принял спасибо, есть ли минусы установки большого ...

Хз, можно компенсировать это ограничив длительность работы таски

0

25.09.2023

Stanislav Evih Автор вопроса

Anatoly
CeleryApp.conf.broker_transport_options = {'visibi...

Если поставить concurrency в 1, может решить проблему что воркеров берут одну и ту же таску?

0

25.09.2023

Stanislav Evih Автор вопроса

Ded
Хз, можно компенсировать это ограничив длительност...

мне нужно отсрочить в большом промежутке времени выполнение таски

0

25.09.2023

Anatoly

Stanislav Evih
Принял спасибо, есть ли минусы установки большого ...

Как по мне - если с воркером беда и он не выполняет задачи (честно, не знаю, в каких случаях такое возможно), то другие воркеры таску не возьмут, пока таймут по видимости не пройдёт. И таски будут висеть в ожидании, хотя есть свободные воркеры.

0

25.09.2023

Anatoly

Stanislav Evih
Если поставить concurrency в 1, может решить пробл...

Мне кажется, нет. Это определяет кол-во concurrent исполняемых тасок, немного не тот параметр

0

25.09.2023

Ded

Anatoly
Как по мне - если с воркером беда и он не выполняе...

При редеплое может случиться

0

25.09.2023