diff --git a/lib/content/createContentHandler.ts b/lib/content/createContentHandler.ts
index b0e845f3..5ee90515 100644
--- a/lib/content/createContentHandler.ts
+++ b/lib/content/createContentHandler.ts
@@ -49,6 +49,7 @@ export async function createContentHandler(request: NextRequest): Promise<NextRe
       captionLength: validated.captionLength,
       upscale: validated.upscale,
       githubRepo,
+      songs: validated.songs,
     };
 
     // Always use allSettled — works for single and batch.
diff --git a/lib/content/validateCreateContentBody.ts b/lib/content/validateCreateContentBody.ts
index 47e3d8fa..81585244 100644
--- a/lib/content/validateCreateContentBody.ts
+++ b/lib/content/validateCreateContentBody.ts
@@ -25,6 +25,7 @@ export const createContentBodySchema = z.object({
   caption_length: z.enum(CAPTION_LENGTHS).optional().default("short"),
   upscale: z.boolean().optional().default(false),
   batch: z.number().int().min(1).max(30).optional().default(1),
+  songs: z.array(z.string().min(1)).optional(),
 });
 
 export type ValidatedCreateContentBody = {
@@ -36,6 +37,7 @@ export type ValidatedCreateContentBody = {
   captionLength: "short" | "medium" | "long";
   upscale: boolean;
   batch: number;
+  songs?: string[];
 };
 
 /**
@@ -94,5 +96,6 @@ export async function validateCreateContentBody(
     captionLength: result.data.caption_length ?? "short",
     upscale: result.data.upscale ?? false,
     batch: result.data.batch ?? 1,
+    songs: result.data.songs,
   };
 }
diff --git a/lib/trigger/triggerCreateContent.ts b/lib/trigger/triggerCreateContent.ts
index 494f7063..c40bd53d 100644
--- a/lib/trigger/triggerCreateContent.ts
+++ b/lib/trigger/triggerCreateContent.ts
@@ -12,6 +12,8 @@ export interface TriggerCreateContentPayload {
   upscale: boolean;
   /** GitHub repo URL so the task can fetch artist files. */
   githubRepo: string;
+  /** Optional list of song slugs to restrict which songs the pipeline picks from. */
+  songs?: string[];
 }
 
 /**