Список тасков, но не результатов.

так а если я таски тоже из генератора получаю?

imap же

(сейчас должны набежать хаскелисты и начать орать про сраные монады)

вот тут и проблема wait(), он так не может

так а если я таски тоже из генератора получаю?

Гхм. Дай ка подумать...

ему туплы подавай

Асинхронный map-reduce получается какой то.

типа того

Окей. А из какого генератора?

вот в 3.6 вроде сделали асинхронные генераторы

надо почитать

Из асинхронного, вроде как, да?

вот в 3.6 вроде сделали асинхронные генераторы

Да. Но это уже совсем жесть.

Да. Но это уже совсем жесть.

отнюдь, имхо, без этого вообще многое неюзабельно :)

типа того же gather(), который громоздит лист в памяти

Окей

Тогда надо написать диспетчер, который эвейтит источник таксков, пихает их в pending.

И вейтить и таски и диспетчер сразу.

Тогда надо написать диспетчер, который эвейтит источник таксков, пихает их в pending.

pending должен быть генератором, а не туплом

и вся проблема сразу решается

async def process(source): pending = source() while len(pending): done, pending =... ...

Да, а возвращать то как? ?

Да, ты прав, @Enchantner , нужен асинхронный генератор.

Да, ты прав, @Enchantner , нужен асинхронный генератор.

сейчас попробую накидать, но я сонный уже

сейчас попробую накидать, но я сонный уже

Я уже прикинул в голове.

вейтим все подряд, шедулим то что пришло в соурс, йелдим то, что done.

Вот только что делать с эксепшенами?

и запиваем смузи

вейтим все подряд, шедулим то что пришло в соурс, йелдим то, что done.

да, все так

Знаешь, @Enchantner , я конечно люблю такие задачки, но вот спать хочу спокойно, по этому, если мне такое понадобится в продакшене, я лучше возьму asyncio.queue

Вот только что делать с эксепшенами?

то же, что и всегда, Пинки

забьем на них хер

ой

то есть

забьем на них хер

????

ну ты понел

Вот если забить, то все просто, а вот если их надо обрабатывать - то этот простой диспетчер превратится в целый фреймворк на 5 тыщ строк.

Так что я лучше возьму очередь.

Вот если забить, то все просто, а вот если их надо обрабатывать - то этот простой диспетчер превратится в целый фреймворк на 5 тыщ строк.

ну, не все так плохо

зависит от того, что мы хотим делать с эксепшнами

по-хорошему, на момент yield они должны быть уже обернуты

Их можно спускать вниз....

Но тогда... Короче нафиг такой хоккей...

Асинхронный генератор кидает асинхронные эксепшены.... Аааааааааа!

Их можно спускать вниз....

это знаешь на что становится похоже?

на go

самое забавное - очередь тебе тут тоже не сильно поможет

Когда я только начал с ботами телеги возиться, мне пришла в голову идея запилить асинхронную машину состояний внутри tornado. Ну чтобы не делать каждый раз state.next_handler(...) а что нибудь типа yield state.wait_next_query() Причем с учетом пришедшего message type. Так вот это задачка того же плана.

Может быть вернусь к этому безумию.

ты будешь смеяться, но я с этой задачкой столкнулся на самой примитивнейшей задаче

у меня есть поток урлов и я его хочу кроулить

но хочу кроулить его я конечным набором воркеров, скажем, сотней

так вот, в случае с gather я этого сделать категорически не могу, потому что он мой красивый генератор на входе соберет со всех корутин и запердолит в список, что мне нафиг не надо

в итоге самый логичный и правильный выход из этого тупика - асинхронные генераторы

в итоге самый логичный и правильный выход из этого тупика - асинхронные генераторы

Мое имхо - очереди.

Мое имхо - очереди.

не для того я в асинхронщину подавался, чтобы многопоточный подход использовать

но так-то да

asyncio.queue - суть тот же chan из go

math.sqrt(numpy.sum(numpy.power((data - neuron), 2))) ошибка unsupported operand type(s) for -: 'map' and 'float' data - это map, neuron - float

math.sqrt(numpy.sum(numpy.power((data - neuron), 2))) ошибка unsupported operand type(s) for -: 'map' and 'float' data - это map, neuron - float

логично, а в чем вопрос?

оберни data в numpy.vector() или как он там

это же векторная операция

вроде просто numpy.array()

Пихаешь в source queue урлы, забираешь из destination queue результаты. Если source или destination переполняется, то await'ы ждут. Вполне себе асинхронно, причем, "воркеров" можно добавлять/убрать динамически.

Пихаешь в source queue урлы, забираешь из destination queue результаты. Если source или destination переполняется, то await'ы ждут. Вполне себе асинхронно, причем, "воркеров" можно добавлять/убрать динамически.

а теперь забабахать для общения между source и destination zeromq - и можно мир покорять

(по крайней мере, я так думал, оно не сработало)

ERROR: S client not available

Я попробую zmq в режиме client/server и расскажу. По идее не должно теряться.

а вообще, если говорить о эксепшнах - то такой код надо уже писать в функциональном стиле, где их быть не должно

вот за это я и не люблю го - туда и эксепшны не завезли, и в функциональном стиле хер напишешь чо

Вопрос подходов. Я эксепшены люблю.

В питоне конечно же. В плюсах - ненавижу.

http://img0.liveinternet.ru/images/attach/c/5/86/189/86189212_ZHirik_mem.jpg

вот за это я и не люблю го - туда и эксепшны не завезли, и в функциональном стиле хер напишешь чо

Там есть panic/recovery.

я эксепшны не очень люблю, но без них никуда

во многих случаях

но, в то же время, из-за своего “явное лучше неявного” эксепшны в питоне стали одним из немногих недостатков синтаксиса

Хех. Помню одну сетевую библиотеку в delphi, там message passing через эксепшены был сделан.

в руби можно foo() rescue callback() написать

в питоне же, чтобы поймать и обработать эксепшен, надо минимум 4 строчки

в питоне же, чтобы поймать и обработать эксепшен, надо минимум 4 строчки

Так же как в плюсах.

Так же как в плюсах.

я привык к if (-1 == func()) error(“OLOLO”)

тоже, по сути, одна строчка

но это, скорее, си

а не c++

я привык к if (-1 == func()) error(“OLOLO”)

Ага. А потом i = 1 напишешь 1 раз и все, прощай последние волосы в паху...

Ага. А потом i = 1 напишешь 1 раз и все, прощай последние волосы в паху...

так для этого единица и ставится на первое место

у тебя на этапе компиляции все упадет же

так для этого единица и ставится на первое место

А меня это всегда бесило. Глаз режет.

А меня это всегда бесило. Глаз режет.

согласен, непривычно, но разумно же

ничонизнаю, -Wall -Werror и у меня тоже упадет на компиляции

или вы игнорите варнинги компилятора?

хочу работать

а работы нет

или вы игнорите варнинги компилятора?

он, сука, игнорит мои комментарии, а я в ответ его ворнинги буду игнорить

а то чо он

а работы нет

а у меня скила :(

а работы нет

работа есть всегда