fix: did not release DB connection after using it
This commit is contained in:
parent
1b714f1a84
commit
e72e817152
@ -18,23 +18,27 @@ const addJobToQueue = (failedCount: number, delay: number) => {
|
|||||||
failedCount: failedCount,
|
failedCount: failedCount,
|
||||||
},
|
},
|
||||||
});
|
});
|
||||||
return;
|
return;
|
||||||
};
|
};
|
||||||
|
|
||||||
export const insertVideosWorker = async (job: Job) => {
|
export const insertVideosWorker = async (job: Job) => {
|
||||||
const failedCount = (job.data.failedCount ?? 0) as number;
|
const failedCount = (job.data.failedCount ?? 0) as number;
|
||||||
const client = await db.connect();
|
const client = await db.connect();
|
||||||
|
|
||||||
await executeTask(client, failedCount);
|
try {
|
||||||
return;
|
await executeTask(client, failedCount);
|
||||||
|
} finally {
|
||||||
|
client.release();
|
||||||
|
}
|
||||||
|
return;
|
||||||
};
|
};
|
||||||
|
|
||||||
const executeTask = async (client: Client, failedCount: number) => {
|
const executeTask = async (client: Client, failedCount: number) => {
|
||||||
logger.log("getLatestVideos now executing", "task");
|
logger.log("getLatestVideos now executing", "task");
|
||||||
const result = await insertLatestVideos(client);
|
const result = await insertLatestVideos(client);
|
||||||
failedCount = result !== 0 ? truncate(failedCount + 1, 0, 5) : 0;
|
failedCount = result !== 0 ? truncate(failedCount + 1, 0, 5) : 0;
|
||||||
if (failedCount !== 0) {
|
if (failedCount !== 0) {
|
||||||
addJobToQueue(failedCount, delayMap[failedCount] * MINUTE);
|
addJobToQueue(failedCount, delayMap[failedCount] * MINUTE);
|
||||||
}
|
}
|
||||||
return;
|
return;
|
||||||
};
|
};
|
||||||
|
Loading…
Reference in New Issue
Block a user