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,