Skip to content

Commit 837d2d6

Browse files
committed
fix: return runner on WorkerService.run
1 parent 5387623 commit 837d2d6

File tree

3 files changed

+8
-10
lines changed

3 files changed

+8
-10
lines changed

package-lock.json

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

package.json

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "nestjs-graphile-worker",
3-
"version": "0.5.0",
3+
"version": "0.5.1",
44
"description": "A Nest.js wrapper for Graphile Worker",
55
"author": "Alexandre Rousseau <alexandre@rsseau.fr>",
66
"private": false,
@@ -87,4 +87,4 @@
8787
"<rootDir>/src/"
8888
]
8989
}
90-
}
90+
}

src/services/worker.service.ts

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
11
import { Inject, Injectable, Logger } from '@nestjs/common';
22
import {
33
Job,
4-
makeWorkerUtils,
5-
run,
64
Runner,
75
RunnerOptions,
8-
runOnce,
96
TaskSpec,
107
WorkerUtils,
8+
makeWorkerUtils,
9+
run,
10+
runOnce,
1111
} from 'graphile-worker';
1212
import { RUNNER_OPTIONS_KEY } from '../interfaces/module-config.interfaces';
1313
import { uniq } from '../utils/array.utils';
@@ -38,9 +38,7 @@ export class WorkerService {
3838

3939
this.logger.debug('Start runner');
4040

41-
const runner = await run(this.options);
42-
await runner.promise;
43-
return runner;
41+
return await run(this.options);
4442
}
4543

4644
/**

0 commit comments

Comments
 (0)