From 27ec317cbbdb9cbb374ba15a51b92d46bf684c47 Mon Sep 17 00:00:00 2001 From: Joe Clark Date: Thu, 16 Apr 2026 10:16:22 +0100 Subject: [PATCH 1/3] add debugging --- .changeset/pretty-eggs-smell.md | 5 +++++ packages/ws-worker/src/events/step-complete.ts | 7 +++++++ 2 files changed, 12 insertions(+) create mode 100644 .changeset/pretty-eggs-smell.md diff --git a/.changeset/pretty-eggs-smell.md b/.changeset/pretty-eggs-smell.md new file mode 100644 index 000000000..b7af0a69e --- /dev/null +++ b/.changeset/pretty-eggs-smell.md @@ -0,0 +1,5 @@ +--- +'@openfn/ws-worker': patch +--- + +Add debug logging to step-complete payloads diff --git a/packages/ws-worker/src/events/step-complete.ts b/packages/ws-worker/src/events/step-complete.ts index 9db844ccf..6d3cd10e0 100644 --- a/packages/ws-worker/src/events/step-complete.ts +++ b/packages/ws-worker/src/events/step-complete.ts @@ -82,5 +82,12 @@ export default async function onStepComplete( Object.assign(evt, reason); + const { output_dataclip, ...eventWithoutDataclip } = evt; + context.logger.debug( + `${context.id} step-complete payload: ${JSON.stringify( + eventWithoutDataclip + )}` + ); + return sendEvent(context, STEP_COMPLETE, evt); } From 0781744f6ece237d637e5e8c3656d1e7991d5edf Mon Sep 17 00:00:00 2001 From: Joe Clark Date: Thu, 16 Apr 2026 10:22:07 +0100 Subject: [PATCH 2/3] version --- .changeset/pretty-eggs-smell.md | 5 ----- packages/ws-worker/CHANGELOG.md | 6 ++++++ packages/ws-worker/package.json | 2 +- 3 files changed, 7 insertions(+), 6 deletions(-) delete mode 100644 .changeset/pretty-eggs-smell.md diff --git a/.changeset/pretty-eggs-smell.md b/.changeset/pretty-eggs-smell.md deleted file mode 100644 index b7af0a69e..000000000 --- a/.changeset/pretty-eggs-smell.md +++ /dev/null @@ -1,5 +0,0 @@ ---- -'@openfn/ws-worker': patch ---- - -Add debug logging to step-complete payloads diff --git a/packages/ws-worker/CHANGELOG.md b/packages/ws-worker/CHANGELOG.md index d65c9455f..fcdd47813 100644 --- a/packages/ws-worker/CHANGELOG.md +++ b/packages/ws-worker/CHANGELOG.md @@ -1,5 +1,11 @@ # ws-worker +## 1.23.7 + +### Patch Changes + +- 27ec317: Add debug logging to step-complete payloads + ## 1.23.6 ### Patch Changes diff --git a/packages/ws-worker/package.json b/packages/ws-worker/package.json index 0f76f7a01..870c829be 100644 --- a/packages/ws-worker/package.json +++ b/packages/ws-worker/package.json @@ -1,6 +1,6 @@ { "name": "@openfn/ws-worker", - "version": "1.23.6", + "version": "1.23.7", "description": "A Websocket Worker to connect Lightning to a Runtime Engine", "main": "dist/index.js", "type": "module", From f33dc9baf03cf8bfb31cd56cf01aa4f6e0aa322c Mon Sep 17 00:00:00 2001 From: Joe Clark Date: Thu, 16 Apr 2026 11:23:23 +0100 Subject: [PATCH 3/3] update for tests --- packages/ws-worker/src/events/step-complete.ts | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/packages/ws-worker/src/events/step-complete.ts b/packages/ws-worker/src/events/step-complete.ts index 6d3cd10e0..4c0640f87 100644 --- a/packages/ws-worker/src/events/step-complete.ts +++ b/packages/ws-worker/src/events/step-complete.ts @@ -83,7 +83,7 @@ export default async function onStepComplete( Object.assign(evt, reason); const { output_dataclip, ...eventWithoutDataclip } = evt; - context.logger.debug( + context.logger?.debug( `${context.id} step-complete payload: ${JSON.stringify( eventWithoutDataclip )}`