Все ноды/Logic & Flow/Synchronization

Дождаться всех

Ждёт завершения активных входящих веток и продолжает поток. Учитывает только реально исполняемые связи (skipped switch-ветки не блокируют). Агрегирует данные согласно merge_mode (first / last / merge). stream_through пробрасывает токены стримящих веток сразу в exit, не дожидаясь барьера (значение всё равно собирается по merge_mode).

Как попробовать

Как применять

Барьер. Берите его, когда несколько веток идут параллельно, а следующий шаг должен начаться только после того, как отработают все — например, два независимых запроса к модели, ответы которых нужны вместе.

Второй повод — требование валидатора. Если две ветки, способные сработать в одном и том же запуске, приходят в один вход, граф не пройдёт проверку: значение той, что пришла раньше, молча перезаписывается той, что пришла позже. Барьер разводит эту гонку.

Барьер не нужен для взаимоисключающих веток (две ветви одного if, on_success и on_error одной ноды): сработает ровно одна, и нода ниже запустится сама, получив её значение. Если ветки дают реплики диалога, посмотрите на messages, если ранжированные списки чанков — на rrf_fusion; это тоже барьеры, но со своим способом сборки результата.

Как это работает

Все входящие связи подключаются к одному порту «Run inputs» — отдельного порта на каждую ветку заводить не нужно. Нода срабатывает, когда ни одна из подключённых веток больше не находится в работе. Пропущенная ветка (не взятая ветвь if или switch) считается разрешённой и барьер не держит. Упавшая — тоже: барьер не будет ждать её вечно, он продолжит с теми значениями, что дошли, а сам сбой отразится на статусе запуска.

Что окажется на выходе, решает «Режим слияния»: first — значение ветки, закончившей первой, last — закончившей последней, merge — список всех пришедших значений. Порядок в списке — порядок завершения веток, а не порядок, в котором вы рисовали связи.

Частые ошибки

• Связь из ноды, стоящей после барьера, обратно в барьер. Барьер начинает ждать сам себя и не сработает никогда; валидация останавливает такой граф как цикл исполнения. Для повторяющихся проходов есть while_loop.
• first читают как «верхнюю ветку». Это ветка, которая закончилась раньше остальных, — на параллельных вызовах модели победитель меняется от запуска к запуску. Нужен конкретный источник — берите merge и обращайтесь к элементу по индексу: {{ nodes.<id>.output[0] }}.
• Ответ перестаёт печататься по мере генерации. Токены модели, идущей в барьер, по умолчанию накапливаются и приходят в чат одним куском в конце. Включите «Пробрасывать стриминг» — работает, когда сразу за барьером идёт exit.

Входы

Выходы

Настройки