diff --git a/packages/workflow-executor/src/executors/base-step-executor.ts b/packages/workflow-executor/src/executors/base-step-executor.ts
index 5c795959f5..60021c0c90 100644
--- a/packages/workflow-executor/src/executors/base-step-executor.ts
+++ b/packages/workflow-executor/src/executors/base-step-executor.ts
@@ -39,18 +39,12 @@ export default abstract class BaseStepExecutor<TStep extends StepDefinition = St
   }
 
   async execute(): Promise<StepExecutionResult> {
-    const { baseRecordRef } = this.context;
-
     this.context.logger('Debug', 'Step context', {
       ...this.logCtx,
-      collection: baseRecordRef.collectionName,
       stepInput: this.context.stepDefinition,
     });
 
-    this.context.logger('Info', 'Step execution started', {
-      ...this.logCtx,
-      collection: baseRecordRef.collectionName,
-    });
+    this.context.logger('Info', 'Step execution started', this.logCtx);
 
     try {
       // Idempotency guard — mutating executors override this. Runs before doExecute so a cache
@@ -391,13 +385,14 @@ export default abstract class BaseStepExecutor<TStep extends StepDefinition = St
   }
 
   protected get logCtx() {
-    const { runId, stepId, stepIndex, stepDefinition } = this.context;
+    const { runId, stepId, stepIndex, stepDefinition, baseRecordRef } = this.context;
 
     return {
       runId,
       stepId,
       stepIndex,
       stepType: stepDefinition.type,
+      collection: baseRecordRef.collectionName,
       ...this.getExtraLogContext(),
     };
   }