diff --git a/src/collections/Emails.ts b/src/collections/Emails.ts
index d86ba6d..503f9aa 100644
--- a/src/collections/Emails.ts
+++ b/src/collections/Emails.ts
@@ -4,7 +4,7 @@ const Emails: CollectionConfig = {
   slug: 'emails',
   admin: {
     useAsTitle: 'subject',
-    defaultColumns: ['subject', 'to', 'status', 'scheduledAt', 'sentAt'],
+    defaultColumns: ['subject', 'to', 'status', 'jobs', 'scheduledAt', 'sentAt'],
     group: 'Mailing',
     description: 'Email delivery and status tracking',
   },
@@ -164,6 +164,24 @@ const Emails: CollectionConfig = {
         description: 'Email priority (1=highest, 10=lowest)',
       },
     },
+    {
+      name: 'jobs',
+      type: 'relationship',
+      relationTo: 'payload-jobs',
+      hasMany: true,
+      admin: {
+        description: 'Processing jobs associated with this email',
+        allowCreate: false,
+        readOnly: true,
+      },
+      filterOptions: ({ id }) => {
+        return {
+          'input.emailId': {
+            equals: id,
+          },
+        }
+      },
+    },
   ],
   timestamps: true,
   // indexes: [
diff --git a/src/sendEmail.ts b/src/sendEmail.ts
index 3b3cafd..d07f91a 100644
--- a/src/sendEmail.ts
+++ b/src/sendEmail.ts
@@ -168,13 +168,19 @@ export const sendEmail = async <TEmail extends BaseEmailDocument = BaseEmailDocu
 
     jobId = String(job.id)
   } catch (error) {
-    if (options.processImmediately) {
-      // If immediate processing was requested, job creation failure is critical
-      throw new Error(`Failed to create job for immediate processing of email ${email.id}: ${error instanceof Error ? error.message : String(error)}`)
-    } else {
-      // For regular queued emails, job creation failure is still critical
-      throw new Error(`Failed to create processing job for email ${email.id}: ${error instanceof Error ? error.message : String(error)}`)
+    // Clean up the orphaned email since job creation failed
+    try {
+      await payload.delete({
+        collection: collectionSlug,
+        id: email.id
+      })
+    } catch (deleteError) {
+      console.error(`Failed to clean up orphaned email ${email.id} after job creation failure:`, deleteError)
     }
+
+    // Throw the original job creation error
+    const errorMsg = `Failed to create processing job for email ${email.id}: ${String(error)}`
+    throw new Error(errorMsg)
   }
 
   // If processImmediately is true, process the job now
@@ -182,7 +188,9 @@ export const sendEmail = async <TEmail extends BaseEmailDocument = BaseEmailDocu
     try {
       await processJobById(payload, jobId)
     } catch (error) {
-      throw new Error(`Failed to process email ${email.id} immediately: ${error instanceof Error ? error.message : String(error)}`)
+      // For immediate processing failures, we could consider cleanup, but the job exists and could be retried later
+      // So we'll leave the email and job in place for potential retry
+      throw new Error(`Failed to process email ${email.id} immediately: ${String(error)}`)
     }
   }
 
diff --git a/src/utils/emailProcessor.ts b/src/utils/emailProcessor.ts
index 3e20d01..c9cbd51 100644
--- a/src/utils/emailProcessor.ts
+++ b/src/utils/emailProcessor.ts
@@ -50,7 +50,7 @@ export async function processJobById(payload: Payload, jobId: string): Promise<v
       }
     })
   } catch (error) {
-    throw new Error(`Failed to process job ${jobId}: ${error instanceof Error ? error.message : String(error)}`)
+    throw new Error(`Failed to process job ${jobId}: ${String(error)}`)
   }
 }