diff --git a/services/worker/src/workers/proxy.js b/services/worker/src/workers/proxy.js index f001156..b4f6f7d 100644 --- a/services/worker/src/workers/proxy.js +++ b/services/worker/src/workers/proxy.js @@ -221,7 +221,8 @@ export const proxyWorker = async (job) => { } catch (error) { console.error(`[proxy] Error processing asset ${assetId}:`, error); await query( - `UPDATE assets SET status = 'error', updated_at = NOW() WHERE id = $1`, + `UPDATE assets SET status = 'error', updated_at = NOW() + WHERE id = $1 AND status NOT IN ('live', 'ingesting')`, [assetId] ); throw error;