Unmute unprocessable span errors

Author: neoxelox

packages/core/src/jobs/job-definitions/documentSuggestions/generateDocumentSuggestionJob.ts

@@ -66,12 +66,8 @@ export const generateDocumentSuggestionJob = async (
     workspace: workspace,
   })
   if (result.error) {
-    if (!(result.error instanceof UnprocessableEntityError)) {
-      throw result.error
-    }
-
-    if (process.env.NODE_ENV === 'development') {
+    if (result.error instanceof UnprocessableEntityError) {
       captureException(result.error)
-    }
+    } else throw result.error
   }
 }

packages/core/src/jobs/job-definitions/tracing/ingestSpansJob.ts

@@ -30,13 +30,9 @@ export const ingestSpansJob = async (job: Job<IngestSpansJobData>) => {
   const result = await ingestSpans({ spans, apiKeyId, workspaceId })
   if (result.error) {
     // @ts-expect-error ingestSpans currently ignores all errors but leaving this for the future
-    if (!(result.error instanceof UnprocessableEntityError)) {
-      throw result.error
-    }
-
-    if (process.env.NODE_ENV === 'development') {
+    if (result.error instanceof UnprocessableEntityError) {
       captureException(result.error)
-    }
+    } else throw result.error
   }
 
   try {

packages/core/src/jobs/job-definitions/tracing/processSegmentJob.ts

@@ -55,7 +55,7 @@ export const processSegmentJob = async (job: Job<ProcessSegmentJobData>) => {
   })
   if (result.error) {
     if (result.error instanceof UnprocessableEntityError) {
-      if (process.env.NODE_ENV === 'development') captureException(result.error)
+      captureException(result.error)
     } else if (result.error instanceof ConflictError) {
       const parts = job.deduplicationId!.split('-')
       const retries = Number(parts.at(-1) ?? 0)

packages/core/src/jobs/job-definitions/tracing/processSpanJob.ts

@@ -42,13 +42,9 @@ export const processSpanJob = async (job: Job<ProcessSpanJobData>) => {
 
   const result = await processSpan({ span, scope, apiKey, workspace })
   if (result.error) {
-    if (!(result.error instanceof UnprocessableEntityError)) {
-      throw result.error
-    }
-
-    if (process.env.NODE_ENV === 'development') {
+    if (result.error instanceof UnprocessableEntityError) {
       captureException(result.error)
-    }
+    } else throw result.error
   }
 
   try {