Skip to content

Commit

Permalink
feat: Queue.jobs add sorting order
Browse files Browse the repository at this point in the history
* feat: add queue delete mutation

* fix: clean console.log

* refactor: return promis from deleteQueue

* fix: remove import

* refactor: pipeline for keys del

* feat: add remove bulk mutation

* fix: add unknown state job

* fix: every type

* feat: order for jobs query

* feat: order for jobs query

* fix: no delete by prefix name

Co-authored-by: Boris Dorofeev <bdorofeev@bdorofeev-laptop.corp.ps.kz>
  • Loading branch information
intpro and Boris Dorofeev authored May 17, 2020
1 parent fb2b02c commit 6c3a7ec
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/helpers/deleteKeys.ts
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ export async function deleteQueue(

const total = await new Promise<number>((resolve, reject) => {
//redis-cli: scan 0 match fullName* count 300
const stream = connection.scanStream({ match: fullName + '*', count: 1000 });
const stream = connection.scanStream({ match: fullName + ':*', count: 1000 });

let total = 0;

Expand Down

0 comments on commit 6c3a7ec

Please sign in to comment.