Skip to content

Commit ffa7689

Browse files
committed
1 parent 5688813 commit ffa7689

File tree

4 files changed

+7
-7
lines changed

4 files changed

+7
-7
lines changed

.changeset/cuddly-apples-buy.md

Lines changed: 0 additions & 5 deletions
This file was deleted.

packages/ws-worker/CHANGELOG.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,11 @@
11
# ws-worker
22

3+
## 1.15.3
4+
5+
### Patch Changes
6+
7+
- 5688813: Allow the worker to shutdown gracefully while claims are still in-flight. Runs will be completed before the server closes
8+
39
## 1.15.2
410

511
### Patch Changes

packages/ws-worker/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@openfn/ws-worker",
3-
"version": "1.15.2",
3+
"version": "1.15.3",
44
"description": "A Websocket Worker to connect Lightning to a Runtime Engine",
55
"main": "dist/index.js",
66
"type": "module",

packages/ws-worker/src/server.ts

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -155,7 +155,6 @@ function connect(app: ServerApp, logger: Logger, options: ServerOptions = {}) {
155155
// handles messages for the worker:queue
156156
const onMessage = (event: string) => {
157157
if (event === WORK_AVAILABLE) {
158-
// TODO ought to have a unit test against this
159158
if (!app.destroyed) {
160159
claim(app, logger, { maxWorkers: options.maxWorkflows }).catch(() => {
161160
// do nothing - it's fine if claim throws here

0 commit comments

Comments
 (0)