Roman
О боже, там же с этим совсем все плохо
Mark ☢️
У меня dp. Решил проблему, отключил в биосе встроенное графическое ядро
Dp это дабл пенетрейшен ?
Anonymous
Народ, в таске celery устанавливается подключение с сервером и выполняются некоторые команды. Вопрос в том что задач много и сервера могут ложиться. Как можно сделать что бы из задачи выполнялись другие задачи но с тем-же подключением?
Anonymous
Прим:
@app.task
def task(opt):
server = astu.connect()
server.process(opt)
server.commit()
server.close()
Хотелось бы как-то так(псевдокод):
@app.task
def task(opt)
server = astu.connect()
server.process(opt)
server.commit()
for i in tasks:
server.process(i["opt"])
server.commit()
server.close()
Aleksandr
>> Как можно сделать что бы из задачи выполнялись другие задачи но с тем-же подключением?
с подключением чего?
Aleksandr
Народ, в таске celery устанавливается подключение с сервером и выполняются некоторые команды. Вопрос в том что задач много и сервера могут ложиться. Как можно сделать что бы из задачи выполнялись другие задачи но с тем-же подключением?
если нужно просто доделать таски, даже если что то сломалось - Task.acks_late = True и retry
Anonymous
Aleksandr
если сам воркер не падает - то решение тожесамое)
Anonymous
На примере, что бы заливать файл по SFTP не по типу "подключился-залил один файл-отключился"
Aleksandr
если падает воркер - ну.. не думаю что есть способ внутри умершего воркера тоже самое подключение использовать
Aleksandr
На примере, что бы заливать файл по SFTP не по типу "подключился-залил один файл-отключился"
нужно делать сессию не в таске , а в воркере
Aleksandr
server = CreateSession(**kwargs)
@app.task(bind=True,(acks_late=True, retry=5)
def task(self,opt):
try:
server.process(opt)
server.commit()
server.close()
except Excaption as e:
self.retry(e)
Aleksandr
например
Aleksandr
но нужно понимать, таски должны быть такими, чтобы повторное их выполнение ничего не ломало
Anonymous
Угу, понял. Но если серверов куча?
Anonymous
Тогда и куча воркеров.. Хм
Anonymous
Ну да. Спасибо)
Aleksandr
Угу, понял. Но если серверов куча?
воркеры и какие-то внешние сервера - ну никак не связаны
Aleksandr
5 серверов - 5 сессий, в нужных тасках - нужная работа
Aleksandr
а воркер 1 может быть
Anonymous
Угу. Про это и подумал
Aleksandr
http://docs.celeryproject.org/en/latest/reference/celery.app.task.html
Anonymous
Я уже дальше продолжу свою мысль, не додумался сессию засадить прямо в воркере
Anonymous
Бля, какие же все, абсолютно все обучающие вебинары по работе с Пайтон говно...... Я вообще не понимаю как люди на них учаться.
Anonymous
Пора наверное на книги переходить
Amir
Всем привет! Есть кто по графам сможет проконсультировать или хотя бы может кто знает что почитать можно?
Задача следующая, есть взвешенный ортограф. Есть несколько начальных точек на выбор и несколько конечных точек, их мы может выбирать. Надо пройти все точки графа с минимальной суммой весов из начальной в конечную. Посоветуйте пожалуйста что почитать, посмотреть, изучать)
Andrey
Amir
Щас гляну!
Amir
Спасибо
Anonymous
Опять я по celery. Можно как-то приостановить все воркеры? Вот упал главный сервер и нужно приостановить воркеры на всех серверах и когда сервер поднимется - поднять их автоматом?
Aleksandr
Anonymous
sleep и чек это не фонтан
Aleksandr
Лучше сессию оберни в объект, который умеет Реконнект
Anonymous
по возможности отрубать из питона функцией если мне нужно
Aleksandr
А если оч надо, смотри бродкаст таски
Anonymous
нене, это не оно. Мне просто интересно есть ли в целери что-то по типу удалённого управления воркерами, flower же как-то умеет
Aleksandr
С учетом прошлого примера, лучше таски таки делать сессию по факту, просто передавать на вход списки данных для выполнения, а не по 1 штуке
Aleksandr
нене, это не оно. Мне просто интересно есть ли в целери что-то по типу удалённого управления воркерами, flower же как-то умеет
Есть, бродкастом можно, есть евенты
Aleksandr
Но я не смог придумать нафига оно может быть маличной мне нужно, при правильном подходе - вроде как и не особо
Anonymous
С учетом прошлого примера, лучше таски таки делать сессию по факту, просто передавать на вход списки данных для выполнения, а не по 1 штуке
Мониторить удобнее будет, больше 5к тасков думаю не будет в день
Aleksandr
Какая оригинальная задача?
Anonymous
Не хочу сейчас объяснять, работа с API если кратко
Anonymous
а методов случеем нет для управления отдельными воркерами? Боюсь смотреть в код flower
Aleksandr
У меня небыло задачи это раскурить- не подскажу
Aleksandr
Но какие то методы, если в доку смотреть , есть в селери
Anonymous
Окей, спасибо. Броадкаст таски думаю будет самое то
Aleksandr
Окей, спасибо. Броадкаст таски думаю будет самое то
Мне кажется надо архитектуру пересматривать, если сигнатуры не менялись - нафига трогать воркеры вообще
Anonymous
Aleksandr
Mark ☢️
Что нет
Mark ☢️
Ты подоконник штоли ?
λ
Там не маздай
Mark ☢️
На правом мониторе маздай
Mark ☢️
Или кде старое
λ
С чего ты так ошибаешся? )
λ
Я патриот! И только лучшие ОС использую
Aleksandr
Как в алхимии заставить item рефрешиться из бд без явного вызова Session.refresh(item) ? Что то типа refresh_timeout
Анастасия
Дорогие друзья и коллеги. Нужен совет. Про приоритезацию тасков и коммуникацию с руководством. Мне сейчас поручают обязанности двух человек - аналитика и маркетолога. Если я оставляю это, я сижу на работе до 22. Если я говорю что давайте подвинем сроки по проектам, то меня не слышат. Более того, когда я попыталась настоять и объяснить, что в одиночку я не справлюсь, руководству это не понравилось. Мы все с этим сталкиваемся: как я могу решить этот вопрос? Интересен ваш положительный опыт. PS руководство меня слышит обычно. Только вчера импульс не прошел наглухо почему-то.
Donald
этот вопрос решается оч просто - сверхурочные оплачиваются по ставке x1.5 первые два часа, дальше x2
Donald
если начальство не желает оплачивать свои хотелки или вы не хотите торчать на работе за любые деньги - ищете новое адекватное начальство на hh
Vladimir
Дорогие друзья и коллеги. Нужен совет. Про приоритезацию тасков и коммуникацию с руководством. Мне сейчас поручают обязанности двух человек - аналитика и маркетолога. Если я оставляю это, я сижу на работе до 22. Если я говорю что давайте подвинем сроки по проектам, то меня не слышат. Более того, когда я попыталась настоять и объяснить, что в одиночку я не справлюсь, руководству это не понравилось. Мы все с этим сталкиваемся: как я могу решить этот вопрос? Интересен ваш положительный опыт. PS руководство меня слышит обычно. Только вчера импульс не прошел наглухо почему-то.
расслабься и получай удовольствие, начальство анализирует как тебя можно припахать)
Анастасия
расслабься и получай удовольствие, начальство анализирует как тебя можно припахать)
А как дать ему правильный сигнал ранжирования что припахать меня можно только за деньги?
Vladimir
работай как работаешь, все же люди. и у всех есть семьи, дети, никто не сидит на работе до 22
Donald
А как дать ему правильный сигнал ранжирования что припахать меня можно только за деньги?
подойти и сказать голосом?
Donald
:D
Donald
чот проиграл с проблем типичного сотрудника
Donald
рабская психология во все поля
Vladimir
А как дать ему правильный сигнал ранжирования что припахать меня можно только за деньги?
напиши смс, я вся твоя за 100000$))
Анастасия
работай как работаешь, все же люди. и у всех есть семьи, дети, никто не сидит на работе до 22
Требуют, чтобы успела всё, как бы. Я вот это не поняла :)
Анастасия
подойти и сказать голосом?
Врубили дурочку, типа "ну и что, у нас все работают за двоих" (на самом деле нет)
Vladimir
Требуют, чтобы успела всё, как бы. Я вот это не поняла :)
ой, требовать могут все, а толку то, как было 24 часа в сутках, так и есть
Donald
врубайте дурочку еще дурее "я не все, ничо низнаю, рабочий день закончен"
Анастасия
рабская психология во все поля
Желание наладить рабочую коммуникацию это рабская психология? Ну ок лол
Vladimir
ага, утюг забыла выключить кажись, а может нет, но надо проверить