Господа, пытаюсь конфигурировать воркеры Celery удаленно и не могу понять, как прислать таск определенному воркеру БЕЗ использования очередей, просто по имени воркера. Гугл предлагает только варианты с назначением каждому воркеру отдельной очереди, что очень тупо
А зачем тебе конкретно между воркерами руками задачи делить?
Ну у меня задача специфическая, требуется инициализировать каждый воркер, проверить, что он работает как надо, а потом уже раздавать всем обычные таски.
Ну у меня задача специфическая, требуется инициализировать каждый воркер, проверить, что он работает как надо, а потом уже раздавать всем обычные таски.
Очень странный кейс проверять что воркеры сельдерея работают норм на уровне тасок
Если я буду использовать multiprocessing.Pool(cnt_count) для вызова f(x) n раз, то как мне гарантировать, что не более cnt_count вызовов f(x) одновременно? Или это так и будет?
В моём случае f(x) будет открывать файловые дескрипторы и не хотелось бы получить краш из-за открытия сотен одновременнно...
Например, я создаю тредпул с cnt_count потоками, то сколько одновременных вызовов функции f может быть? Может, ли их быть больше чем количество потоков?(По факту симуляция многопоточности на одном ядре, но мне такое не нужно).
Я хочу огранить количество одновременных вызовов функции количеством созданных потоков...
Может кто-нибудь знает или разбирается в Python`e, то такой вопрос(он глупый), как сделать так, чтобы функция сработала только 1 раз? Пробовал искать в интернете, ютубе и т.д., но, к сожелению, не нашёл
Может кто-нибудь знает или разбирается в Python`e, то такой вопрос(он глупый), как сделать так, чтобы функция сработала только 1 раз? Пробовал искать в интернете, ютубе и т.д., но, к сожелению, не нашёл
зависит от контекста, вариантов решений несколько. Если это метод класса то оч легко сделать триггер. Если просто функция то декоратором тоже не сложно сделать. И что значит только 1 раз? Что она будет делать при последующих вызовах? Что возвращать? Надо конкретней задачу