diff --git a/apps/worker/src/jobs/events.ts b/apps/worker/src/jobs/events.ts
index 40d7e7ee..c8811d1b 100644
--- a/apps/worker/src/jobs/events.ts
+++ b/apps/worker/src/jobs/events.ts
@@ -11,6 +11,9 @@ import { createSessionEnd } from './events.create-session-end';
 export async function eventsJob(job: Job<EventsQueuePayload>) {
   switch (job.data.type) {
     case 'createEvent': {
+      if (job.attemptsStarted > 1 && job.data.payload.duration < 0) {
+        job.data.payload.duration = 0;
+      }
       return await createEvent(job.data.payload);
     }
   }