minor: create evaluation result transactionally with the evaluation run

latitude-dev · Sep 13, 2024 · 806e3ed · 806e3ed
1 parent b6436d3
commit 806e3ed
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/packages/core/src/services/evaluations/run.ts b/packages/core/src/services/evaluations/run.ts
@@ -65,7 +65,7 @@ export const runEvaluation = async (
   if (result.error) return result
 
   result.value.response.then((response) => {
-    publisher.publishLater({
+    publisher.publish({
       type: 'evaluationRun',
       data: {
         evaluationId: evaluation.id,

diff --git a/packages/jobs/src/job-definitions/batchEvaluations/runEvaluationJob.ts b/packages/jobs/src/job-definitions/batchEvaluations/runEvaluationJob.ts
@@ -31,10 +31,12 @@ export const runEvaluationJob = async (job: Job<RunEvaluationJobData>) => {
       .find(evaluationId)
       .then((r) => r.unwrap())
 
-    await runEvaluation({
+    const { response } = await runEvaluation({
       documentLog,
       evaluation,
-    })
+    }).then((r) => r.unwrap())
+
+    await response
 
     await progressTracker.incrementCompleted()
   } catch (error) {