prevent SDK retry from crashing on circular errors

src/queue-processors/base-queue-processor.ts

@@ -121,7 +121,14 @@ export abstract class BaseQueueProcessor<
       return { status: "success" };
     } catch (err) {
       const decision = this.getRetryDecision(err, job);
-      this.logProcessingError(jobId, err, decision);
+      try {
+        this.logProcessingError(jobId, err, decision);
+      } catch (logErr) {
+        console.error(
+          `[job:${jobId}] logProcessingError threw`,
+          logErr instanceof Error ? logErr.message : String(logErr),
+        );
+      }
       if (decision.shouldRetry) {
         try {
           const attempts = await this.retryJob(job, decision.options);

src/utils/log-utils.ts

@@ -1,10 +1,27 @@
 const JSON_INDENT = 2;
 
+function getCircularReplacer(): (key: string, value: unknown) => unknown {
+  const seen = new WeakSet<object>();
+  return (_key, value) => {
+    if (typeof value === "object" && value !== null) {
+      if (seen.has(value as object)) {
+        return "[Circular]";
+      }
+      seen.add(value as object);
+    }
+    return value;
+  };
+}
+
 export function serializeError(detail: unknown): string {
   if (detail instanceof Error) {
     const { name, message, ...rest } = detail as Error &
       Record<string, unknown>;
-    return JSON.stringify({ name, message, ...rest }, null, JSON_INDENT);
+    return JSON.stringify(
+      { name, message, ...rest },
+      getCircularReplacer(),
+      JSON_INDENT,
+    );
   }
-  return JSON.stringify(detail, null, JSON_INDENT);
+  return JSON.stringify(detail, getCircularReplacer(), JSON_INDENT);
 }