diff --git a/app/messages/api/queue/insert-messages.ts b/app/messages/api/queue/insert-messages.ts
index 0834fc5..93a0647 100644
--- a/app/messages/api/queue/insert-messages.ts
+++ b/app/messages/api/queue/insert-messages.ts
@@ -35,7 +35,7 @@ const insertMessagesQueue = Queue<Payload>(
 			}))
 			.sort((a, b) => a.sentAt.getTime() - b.sentAt.getTime());
 
-		await db.message.createMany({ data: sms });
+		await db.message.createMany({ data: sms, skipDuplicates: true });
 	},
 );
 
diff --git a/app/phone-calls/api/queue/fetch-calls.ts b/app/phone-calls/api/queue/fetch-calls.ts
index ef0732c..c06a18c 100644
--- a/app/phone-calls/api/queue/fetch-calls.ts
+++ b/app/phone-calls/api/queue/fetch-calls.ts
@@ -15,6 +15,7 @@ const fetchCallsQueue = Queue<Payload>("api/queue/fetch-calls", async ({ organiz
 		include: { organization: true },
 	});
 	if (!phoneNumber) {
+		console.log("no phone number found");
 		return;
 	}
 
diff --git a/app/phone-calls/api/queue/insert-calls.ts b/app/phone-calls/api/queue/insert-calls.ts
index 71044cf..32e4fb7 100644
--- a/app/phone-calls/api/queue/insert-calls.ts
+++ b/app/phone-calls/api/queue/insert-calls.ts
@@ -32,7 +32,7 @@ const insertCallsQueue = Queue<Payload>("api/queue/insert-calls", async ({ calls
 		}))
 		.sort((a, b) => a.createdAt.getTime() - b.createdAt.getTime());
 
-	await db.phoneCall.createMany({ data: phoneCalls });
+	await db.phoneCall.createMany({ data: phoneCalls, skipDuplicates: true });
 });
 
 export default insertCallsQueue;