mirror of
https://github.com/tdurieux/anonymous_github.git
synced 2026-05-15 22:48:00 +02:00
chore(deps): bump uuid and bullmq (#691)
* chore(deps): bump uuid and bullmq Removes [uuid](https://github.com/uuidjs/uuid). It's no longer used after updating ancestor dependency [bullmq](https://github.com/taskforcesh/bullmq). These dependencies need to be updated together. Removes `uuid` Updates `bullmq` from 2.4.0 to 5.76.5 - [Release notes](https://github.com/taskforcesh/bullmq/releases) - [Commits](https://github.com/taskforcesh/bullmq/compare/v2.4.0...v5.76.5) --- updated-dependencies: - dependency-name: bullmq dependency-version: 5.76.5 dependency-type: direct:production - dependency-name: uuid dependency-version: dependency-type: indirect ... Signed-off-by: dependabot[bot] <support@github.com> * fix(bullmq): adapt isRunning + getJobs typing for v5 API Worker.isRunning became a method (was a property in v2), and Queue.getJobs now requires a mutable JobType[] (was string[]). * clean up --------- Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: tdurieux <durieuxthomas@hotmail.com> Co-authored-by: Thomas Durieux <5577568+tdurieux@users.noreply.github.com>
This commit is contained in:
@@ -40,7 +40,7 @@ const QUEUE_STATES = [
|
||||
"completed",
|
||||
"failed",
|
||||
"delayed",
|
||||
] as const;
|
||||
] as JobType[];
|
||||
|
||||
function pickQueue(name: string): Queue | null {
|
||||
if (name === "download") return downloadQueue;
|
||||
@@ -169,11 +169,10 @@ router.post("/queue/:name/drain", async (req, res) => {
|
||||
|
||||
router.get("/queues", async (req, res) => {
|
||||
const search = req.query.search ? String(req.query.search).toLowerCase() : "";
|
||||
const stateFilter = req.query.state ? String(req.query.state) : null;
|
||||
const states: JobType[] =
|
||||
stateFilter && (QUEUE_STATES as readonly string[]).includes(stateFilter)
|
||||
? [stateFilter as JobType]
|
||||
: ([...QUEUE_STATES] as JobType[]);
|
||||
const stateFilter: JobType | null = req.query.state ? String(req.query.state) as JobType : null;
|
||||
const states: JobType[] = stateFilter && QUEUE_STATES.includes(stateFilter)
|
||||
? [stateFilter]
|
||||
: QUEUE_STATES;
|
||||
|
||||
const [download, remove, cache, dCounts, rCounts, cCounts] = await Promise.all([
|
||||
downloadQueue.getJobs(states),
|
||||
|
||||
Reference in New Issue
Block a user