diff --git a/src/utils/jobScheduler.ts b/src/utils/jobScheduler.ts
index 373787b..ff7fc5b 100644
--- a/src/utils/jobScheduler.ts
+++ b/src/utils/jobScheduler.ts
@@ -73,8 +73,8 @@ export async function ensureEmailJob(
       jobId: job.id,
       emailId: normalizedEmailId,
       scheduledAt: options?.scheduledAt || 'immediate',
-      task: job.task,
-      queue: job.queue
+      task: 'process-email',
+      queue: queueName
     })
 
     return {