fast fix for duration issue

2024-02-28 22:32:52 +01:00
parent 5bfe0b9e35
commit 753df48296
1 changed files with 3 additions and 0 deletions
--- 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);
    }
  }