Skip to content

Commit 3f9e9a4

Browse files
Boris Dorofeevnodkz
Boris Dorofeev
authored andcommitted
fix: job removed without data
1 parent 32e7527 commit 3f9e9a4

File tree

1 file changed

+0
-4
lines changed

1 file changed

+0
-4
lines changed

src/subscriptions/onJobRemoved.ts

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
import { SchemaComposer, ObjectTypeComposerFieldConfigAsObjectDefinition } from 'graphql-compose';
2-
import { getJobTC } from '../types/job/Job';
32
import { getQueue } from '../helpers';
43
import { Options } from '../definitions';
54
import { getAsyncIterator } from '../helpers';
@@ -13,7 +12,6 @@ export function createOnJobRemovedFC(
1312
type: sc.createObjectTC({
1413
name: 'OnJobRemovedPayload',
1514
fields: {
16-
job: getJobTC(sc, opts),
1715
queue: getQueueTC(sc, opts).NonNull,
1816
jobId: 'String!',
1917
queueName: 'String!',
@@ -29,9 +27,7 @@ export function createOnJobRemovedFC(
2927
},
3028
resolve: async ({ jobId, prev }, { prefix, queueName }) => {
3129
const queue = getQueue(prefix, queueName, opts);
32-
const job = await queue.getJob(jobId);
3330
return {
34-
job,
3531
queue,
3632
jobId,
3733
queueName,

0 commit comments

Comments
 (0)