getsentry · sentry · Aug 13, 2026 · cursor · Aug 13, 2026
@@ -4,6 +4,7 @@ import type { AddEventResult, EventBuffer, EventBufferType, RecordingEvent } fro
 import { debug } from '../util/logger';
 import { EventBufferArray } from './EventBufferArray';
 import { EventBufferCompressionWorker } from './EventBufferCompressionWorker';
+import { WorkerDestroyedError } from './error';
 
 /**
  * This proxy will try to use the compression worker, and fall back to use the simple buffer if an error occurs there.
@@ -130,6 +131,12 @@ export class EventBufferProxy implements EventBuffer {
       // Can now clear fallback buffer as it's no longer necessary
       this._fallback.clear();
     } catch (error) {
+      // If the worker was intentionally destroyed (e.g. on session expiry) while
+      // events were still being compressed, silently ignore the rejection — it is
+      // expected behaviour and not worth reporting to Sentry.
+      if (error instanceof WorkerDestroyedError) {
+        return;
+      }
       DEBUG_BUILD && debug.exception(error, 'Failed to add events when switching buffers.');
     }
   }

@@ -1,6 +1,7 @@
 import { DEBUG_BUILD } from '../debug-build';
 import type { WorkerRequest, WorkerResponse } from '../types';
 import { debug } from '../util/logger';
+import { WorkerDestroyedError } from './error';
 
 interface PendingRequest {
   method: WorkerRequest['method'];
@@ -75,7 +76,7 @@ export class WorkerHandler {
   public destroy(): void {
     DEBUG_BUILD && debug.log('Destroying compression worker');
     this._worker.removeEventListener('message', this._onMessage);
-    this._pending.forEach(pending => pending.reject(new Error('Worker destroyed')));
+    this._pending.forEach(pending => pending.reject(new WorkerDestroyedError()));
     this._pending.clear();
     this._worker.terminate();
   }

@@ -6,3 +6,10 @@ export class EventBufferSizeExceededError extends Error {
     super(`Event buffer exceeded maximum size of ${REPLAY_MAX_EVENT_BUFFER_SIZE}.`);
   }
 }
+
+/** This error indicates that the compression worker was intentionally destroyed (e.g. on session expiry). */
+export class WorkerDestroyedError extends Error {
+  public constructor() {
+    super('Worker destroyed');
+  }
+}