mirror of
https://github.com/zoriya/Kyoo.git
synced 2025-11-21 14:03:21 -05:00
Fix image downloading error handling
This commit is contained in:
parent
31500dc3c5
commit
c1b243df9c
@ -99,13 +99,15 @@ export const processImages = async () => {
|
|||||||
const column = sql.raw(img.column);
|
const column = sql.raw(img.column);
|
||||||
|
|
||||||
await tx.execute(sql`
|
await tx.execute(sql`
|
||||||
update ${table} set ${column} = ${ret} where ${column}->'id' = ${sql.raw(`'"${img.id}"'::jsonb`)}
|
update ${table} set ${column} = ${ret}
|
||||||
|
where ${column}->'id' = ${sql.raw(`'"${img.id}"'::jsonb`)}
|
||||||
`);
|
`);
|
||||||
|
|
||||||
await tx.delete(mqueue).where(eq(mqueue.id, item.id));
|
await tx.delete(mqueue).where(eq(mqueue.id, item.id));
|
||||||
} catch (err: any) {
|
} catch (err: any) {
|
||||||
console.error("Failed to download image", img.url, err.message);
|
console.error("Failed to download image", img.url, err.message);
|
||||||
await tx
|
// don't use the transaction here, it can be aborted.
|
||||||
|
await db
|
||||||
.update(mqueue)
|
.update(mqueue)
|
||||||
.set({ attempt: sql`${mqueue.attempt}+1` })
|
.set({ attempt: sql`${mqueue.attempt}+1` })
|
||||||
.where(eq(mqueue.id, item.id));
|
.where(eq(mqueue.id, item.id));
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user