From b0f504ca6976adb529b24b9772e957a036191a6d Mon Sep 17 00:00:00 2001
From: ZGaetano <zgaetano@wilddragon.net>
Date: Tue, 2 Jun 2026 18:38:21 -0400
Subject: [PATCH] =?UTF-8?q?feat/fix:=20thumbnail.js=20=E2=80=94=20growing?=
 =?UTF-8?q?=20migrate=20flow=20+=20deltacast=20cleanup?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 services/worker/src/workers/thumbnail.js | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/services/worker/src/workers/thumbnail.js b/services/worker/src/workers/thumbnail.js
index 8dabddc..7ed39c8 100644
--- a/services/worker/src/workers/thumbnail.js
+++ b/services/worker/src/workers/thumbnail.js
@@ -40,6 +40,18 @@ export const thumbnailWorker = async (job) => {
   const outputPath = join(tmpDir, `thumb-output-${job.id}.jpg`);
 
   try {
+    // Check asset status before doing any work
+    const assetRow = await query(
+      'SELECT status FROM assets WHERE id = $1',
+      [assetId]
+    );
+    const asset = assetRow.rows[0];
+
+    if (asset?.status === 'pending_migration') {
+      console.log(`[thumbnail] asset ${assetId} is pending_migration, skipping`);
+      return;
+    }
+
     // Download proxy from S3
     await job.updateProgress(10);
     console.log(`[thumbnail] Downloading ${proxyKey} for asset ${assetId}`);