Параллельность и ресурсы

concurrency управляет ветками, допуском запусков и временным владением ресурсом. Параметры зависят от места применения.

Параметры

Поле	Где и для чего	По умолчанию
limit	Допуск запусков / веток / владельцев ресурса	4 / 2 / 1
on_busy	Для запусков и ресурса: ожидание или иная реакция	wait
supersession_key	Эквивалентность заменяемых запусков	Не задано
branches	Именованные ветки steps + outputs	Для параллельных веток
on_error	Ошибки веток: fail или collect	fail
resource	Ключ ресурса внутри аккаунта	Для резервирования
lifetime	Владение до конца участка (step) или запуска (run)	step
protected	Защита короткой внешней записи	false
steps, outputs	Участок под резервом и его результат	Пустые
when	Условие выполнения участка/ветвления	Без условия

Пример

YAMLДве независимые ветки

- id: parallel
  concurrency:
    limit: 2
    on_error: collect
    branches:
      products:
        steps:
          - id: fetch
            block: http
            params:
              url: "{inputs.products_url}"
        outputs:
          items: "{fetch.json}"
      prices:
        steps:
          - id: fetch
            block: http
            params:
              url: "{inputs.prices_url}"
        outputs:
          items: "{fetch.json}"

Ветки используют разные источники. Одинаковое внутреннее имя fetch не смешивает результаты.

Результат

Ветки: branches: {name: {status, output, error}}. Резерв: acquired, output; при пропуске — false, null. Допуск запусков задаёт порядок выполнения и не создаёт результат блока.

Поведение

Ветвление дожидается всех веток; ручное ожидание не считается ошибкой. Лимиты веток и запусков действуют одновременно. Для очередей и резервов нужно постоянное хранилище; SDK без него отказывает до действий.

Запуски workflow

YAMLПоля верхнего уровня workflow

concurrency:
  limit: 1
  on_busy: wait

limit=1 сериализует запуски. latest_waiting заменяет эквивалентную ожидающую работу, supersede также запрашивает остановку активной; оба требуют limit=1 и supersession_key.

Резервирование

YAMLЗанять ресурс до окончания запуска

- id: claim
  concurrency:
    resource: "{inputs.resource_key}"
    limit: 1
    lifetime: run
    on_busy: skip

При занятости: wait — ждать, skip — пропустить без действий и без заявки на ожидание, fail — ошибка. Пустой участок допустим только для lifetime=run.

Резерв сохраняется через согласование и перезапуск. Повторное получение своим запуском использует тот же резерв; после завершения он освобождается. Воркеры получают ресурс согласованно; разные limit одного ключа отклоняются. Внутри занятого участка можно получить только пустой резерв lifetime: run с on_busy: skip или fail, до начала защищённой записи. Вложенное ожидание запрещено; ключ не содержит секретов.

Например, временное владение изображением и постоянная отметка «уже использовано» — разные вещи: постоянная история хранится в данных приложения.

Защита записи

protected откладывает отмену на время короткой записи и сохранения результата. Согласование внутри участка запрещено. Если запись могла выполниться, ресурс остаётся на проверку вместо автоматического освобождения и повтора.