Skip to content

Commit f9cc7c5

Browse files
intproBoris Dorofeev
and
Boris Dorofeev
authored
fix: remove repeatable job
* fix: return non nullable key field * feat: right method for delete removeRepeatable Co-authored-by: Boris Dorofeev <[email protected]>
1 parent 9d40bf6 commit f9cc7c5

File tree

1 file changed

+13
-7
lines changed

1 file changed

+13
-7
lines changed

src/mutation/queueRemoveRepeatable.ts

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,22 +11,28 @@ export function createRemoveRepeatableFC(
1111
return {
1212
type: sc.createObjectTC({
1313
name: `${typePrefix}QueueRemoveRepeatablePayload`,
14-
fields: {
15-
key: 'String!',
16-
},
1714
}),
1815
args: {
1916
prefix: {
2017
type: 'String!',
2118
defaultValue: 'bull',
2219
},
2320
queueName: 'String!',
24-
key: 'String!',
21+
jobName: 'String',
22+
repeat: sc.createInputTC({
23+
name: `${typePrefix}JobOptionsInputRepeatRemove`,
24+
fields: {
25+
tz: 'String',
26+
endDate: 'Date',
27+
cron: 'String',
28+
every: 'String',
29+
},
30+
}).NonNull,
2531
},
26-
resolve: async (_, { prefix, queueName, key }) => {
32+
resolve: async (_, { prefix, queueName, jobName, repeat }) => {
2733
const queue = await findQueue(prefix, queueName, opts);
28-
await queue.removeRepeatableByKey(key);
29-
return { key };
34+
await queue.removeRepeatable(jobName, repeat);
35+
return {};
3036
},
3137
};
3238
}

0 commit comments

Comments
 (0)