From 4a254737eb88f6f34df20c6de0e5ecac74cd80d8 Mon Sep 17 00:00:00 2001
From: Joe Clark <jclark@openfn.org>
Date: Fri, 24 Apr 2026 11:59:04 +0100
Subject: [PATCH] add debug logging

---
 .changeset/pretty-lines-shout.md           | 5 +++++
 packages/engine-multi/src/api/lifecycle.ts | 5 ++++-
 2 files changed, 9 insertions(+), 1 deletion(-)
 create mode 100644 .changeset/pretty-lines-shout.md

diff --git a/.changeset/pretty-lines-shout.md b/.changeset/pretty-lines-shout.md
new file mode 100644
index 000000000..3ef3c0df6
--- /dev/null
+++ b/.changeset/pretty-lines-shout.md
@@ -0,0 +1,5 @@
+---
+'@openfn/engine-multi': patch
+---
+
+Add debugging to for step start/complete
diff --git a/packages/engine-multi/src/api/lifecycle.ts b/packages/engine-multi/src/api/lifecycle.ts
index 3de02cfcd..6bbf7bc96 100644
--- a/packages/engine-multi/src/api/lifecycle.ts
+++ b/packages/engine-multi/src/api/lifecycle.ts
@@ -14,7 +14,6 @@ export const workflowStart = (
 ) => {
   const { state, logger } = context;
   const { workflowId, threadId } = event;
-
   logger.info('starting workflow ', workflowId);
 
   // where would this throw get caught?
@@ -68,7 +67,9 @@ export const jobStart = (
   context: ExecutionContext,
   event: internalEvents.JobStartEvent
 ) => {
+  const { logger,state} = context;
   const { threadId, jobId } = event;
+  logger.debug(`${state.id}: sending job start (step start): ${event.jobId}`)
 
   context.emit(externalEvents.JOB_START, {
     jobId,
@@ -81,7 +82,9 @@ export const jobComplete = (
   context: ExecutionContext,
   event: internalEvents.JobCompleteEvent
 ) => {
+  const { logger, state: runState } = context;
   const { threadId, state, duration, jobId, next, mem, redacted } = event;
+  logger.debug(`${runState.id}: sending job complete (step complete): ${event.jobId}`)
 
   context.emit(externalEvents.JOB_COMPLETE, {
     threadId,