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", diff --git a/packages/ws-worker/src/events/step-complete.ts b/packages/ws-worker/src/events/step-complete.ts index 9db844ccf..4c0640f87 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); }