diff --git a/packages/app-store/zapier/lib/nodeScheduler.ts b/packages/app-store/zapier/lib/nodeScheduler.ts index 6aa7b0bdab..f0096a9f43 100644 --- a/packages/app-store/zapier/lib/nodeScheduler.ts +++ b/packages/app-store/zapier/lib/nodeScheduler.ts @@ -49,7 +49,8 @@ export async function scheduleTrigger( export async function cancelScheduledJobs( booking: { uid: string; scheduledJobs?: string[] }, - appId?: string | null + appId?: string | null, + isReschedule?: boolean ) { let scheduledJobs = booking.scheduledJobs || []; @@ -70,14 +71,16 @@ export async function cancelScheduledJobs( scheduledJobs = []; } - await prisma.booking.update({ - where: { - uid: booking.uid, - }, - data: { - scheduledJobs: scheduledJobs, - }, - }); + if (!isReschedule) { + await prisma.booking.update({ + where: { + uid: booking.uid, + }, + data: { + scheduledJobs: scheduledJobs, + }, + }); + } }); } } diff --git a/packages/features/bookings/lib/handleNewBooking.ts b/packages/features/bookings/lib/handleNewBooking.ts index 65af9330f7..3f37f65306 100644 --- a/packages/features/bookings/lib/handleNewBooking.ts +++ b/packages/features/bookings/lib/handleNewBooking.ts @@ -887,7 +887,7 @@ async function handler(req: NextApiRequest & { userId?: number | undefined }) { subscribersMeetingEnded.forEach((subscriber) => { if (rescheduleUid && originalRescheduledBooking) { - cancelScheduledJobs(originalRescheduledBooking); + cancelScheduledJobs(originalRescheduledBooking, undefined, true); } if (booking && booking.status === BookingStatus.ACCEPTED) { scheduleTrigger(booking, subscriber.subscriberUrl, subscriber);