harn-stdlib 0.8.12

Embedded Harn standard library source catalog
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141

fn __as_candidate(value, index) {
  if type_of(value) == "string" {
    return {index: index, prompt: value, instruction: value, demos: []}
  }
  require type_of(value) == "dict", "parallel_judge: candidates must be strings or dicts"
  let instruction = value?.instruction ?? value?.prompt ?? ""
  let prompt = value?.prompt ?? instruction
  return value
    + {index: value?.index ?? index, prompt: prompt, instruction: instruction, demos: value?.demos ?? []}
}

fn __candidate_rows(candidates) {
  let candidate_list = if type_of(candidates) == "list" {
    candidates
  } else {
    [candidates]
  }
  require len(candidate_list) > 0, "parallel_judge: candidates must not be empty"
  var rows = []
  var idx = 0
  while idx < len(candidate_list) {
    rows = rows.push({index: idx, candidate: __as_candidate(candidate_list[idx], idx)})
    idx = idx + 1
  }
  return rows
}

fn __case_rows(eval_set) {
  require type_of(eval_set) == "list", "parallel_judge: eval_set must be a list"
  require len(eval_set) > 0, "parallel_judge: eval_set must not be empty"
  var rows = []
  var idx = 0
  while idx < len(eval_set) {
    rows = rows.push({index: idx, case: eval_set[idx]})
    idx = idx + 1
  }
  return rows
}

fn __case_id(case, index) {
  if type_of(case) == "dict" && case?.id != nil {
    return case.id
  }
  return "case-" + to_string(index)
}

fn __score_value(value) {
  let raw = if type_of(value) == "dict" {
    value?.score
  } else {
    value
  }
  let score = to_float(raw)
  require score != nil, "parallel_judge: metric must return a numeric score or {score}"
  return score
}

fn __score_case(candidate, case, case_index, candidate_index, metric) {
  let output = metric(
    {
      prompt: candidate.prompt,
      candidate: candidate,
      case: case,
      case_index: case_index,
      candidate_index: candidate_index,
    },
  )
  return {
    case_id: __case_id(case, case_index),
    case_index: case_index,
    score: __score_value(output),
    output: output,
  }
}

fn __mean_case_score(case_scores) {
  var total = 0.0
  for row in case_scores {
    total = total + row.score
  }
  return total / (len(case_scores) * 1.0)
}

fn __insert_ranked(ranked, entry) {
  var out = []
  var inserted = false
  for existing in ranked {
    if !inserted && entry.score > existing.score {
      out = out.push(entry)
      inserted = true
    }
    out = out.push(existing)
  }
  if !inserted {
    out = out.push(entry)
  }
  return out
}

fn __rank(entries) {
  var ranked = []
  for entry in entries {
    ranked = __insert_ranked(ranked, entry)
  }
  return ranked
}

/** Score candidate prompts against an eval set, evaluating cases in parallel. */
pub fn parallel_judge(candidates, eval_set, metric, options = nil) {
  require metric != nil, "parallel_judge: metric closure is required"
  let candidate_rows = __candidate_rows(candidates)
  let case_rows = __case_rows(eval_set)
  let _max_concurrent = options?.max_concurrent ?? options?.budget?.max_concurrent
  var scored = []
  for row in candidate_rows {
    let candidate = row.candidate
    let case_scores = parallel each case_rows with { max_concurrent: _max_concurrent } { case_row ->
      __score_case(candidate, case_row.case, case_row.index, row.index, metric)
    }
    scored = scored
      .push(
      {
        index: row.index,
        candidate: candidate,
        prompt: candidate.prompt,
        score: __mean_case_score(case_scores),
        case_scores: case_scores,
      },
    )
  }
  let ranked = __rank(scored)
  return {
    ranked: ranked,
    scores: scored,
    best: if len(ranked) > 0 {
      ranked[0]
    } else {
      nil
    },
  }
}