diff --git a/packages/api/src/jobs/email/send_email.ts b/packages/api/src/jobs/email/send_email.ts index 416cf94f0..8063bbe5a 100644 --- a/packages/api/src/jobs/email/send_email.ts +++ b/packages/api/src/jobs/email/send_email.ts @@ -24,6 +24,7 @@ export type SendEmailJobData = Merge< > export const sendEmailJob = async (data: SendEmailJobData) => { + logger.info('sending email job:', { data }) if (!data.to) { const user = await findActiveUser(data.userId) if (!user) { diff --git a/packages/api/src/services/send_emails.ts b/packages/api/src/services/send_emails.ts index ed5c64307..a766d5f52 100644 --- a/packages/api/src/services/send_emails.ts +++ b/packages/api/src/services/send_emails.ts @@ -144,6 +144,12 @@ export const sendExportJobEmail = async ( throw new Error('Invalid state') } + logger.info('enqueing email job:', { + userId, + subject, + html, + }) + return enqueueSendEmail({ userId, subject,