Function run_batch_inputs_step

app/workflow/workflow.cpp:269–338

        context.values[key] = value;
    }
    for (auto & [_, value] : context.values) {
        value = expand_value(value, context);
    }
}

void run_batch_inputs_step(
    const engine::io::json::Value & step,
    WorkflowContext & context) {
    const std::string id = workflow_string(step, "id");
    if (workflow_has_field(step, "foreach")) {
        throw std::runtime_error("batch_inputs cannot use foreach: " + id);
    }
    const bool has_audio_dir = workflow_has_field(step, "audio_dir");
    const bool has_text_dir = workflow_has_field(step, "text_dir");
    if ((has_audio_dir ? 1 : 0) + (has_text_dir ? 1 : 0) != 1) {
        throw std::runtime_error("batch_inputs requires exactly one of audio_dir or text_dir: " + id);
    }

    std::vector<std::filesystem::path> paths;
    std::vector<std::unordered_map<std::string, std::string>> items;
    if (has_audio_dir) {
        const auto dir = resolve_workflow_path(workflow_string(step, "audio_dir"), context);
        if (!std::filesystem::is_directory(dir)) {
            throw std::runtime_error("batch_inputs audio_dir must be an existing directory: " + dir.string());
        }
        for (const auto & entry : std::filesystem::directory_iterator(dir)) {
            if (entry.is_regular_file() && is_wav_path(entry.path())) {
                paths.push_back(entry.path());
            }
        }
        std::sort(paths.begin(), paths.end());
        if (paths.empty()) {
            throw std::runtime_error("batch_inputs audio_dir contains no .wav files: " + dir.string());
        }
        items.reserve(paths.size());
        for (const auto & path : paths) {
            items.push_back({
                {"id", safe_workflow_id(path.stem().string())},
                {"audio_path", path.string()},
            });
        }
    } else {
        const auto dir = resolve_workflow_path(workflow_string(step, "text_dir"), context);
        if (!std::filesystem::is_directory(dir)) {
            throw std::runtime_error("batch_inputs text_dir must be an existing directory: " + dir.string());
        }
        for (const auto & entry : std::filesystem::directory_iterator(dir)) {
            if (entry.is_regular_file() && is_text_batch_path(entry.path())) {
                paths.push_back(entry.path());
            }
        }
        std::sort(paths.begin(), paths.end());
        if (paths.empty()) {
            throw std::runtime_error("batch_inputs text_dir contains no .txt, .md, or .json files: " + dir.string());
        }
        items.reserve(paths.size());
        for (const auto & path : paths) {
            const auto text = read_batch_text_payload(path);