fix(logs): redact executionData.correlation

The top-level correlation field is copied from pre-redaction trigger data, so
webhook/schedule correlation values could persist unredacted. Add it to the
redaction set alongside trigger/environment.

Author: TheodoreSpeaks

apps/sim/lib/logs/execution/logger.ts

@@ -770,6 +770,9 @@ export class ExecutionLogger implements IExecutionLoggerService {
       ...(builtExecutionData.environment !== undefined
         ? { environment: builtExecutionData.environment }
         : {}),
+      ...(builtExecutionData.correlation !== undefined
+        ? { correlation: builtExecutionData.correlation }
+        : {}),
     })
 
     const rawDurationMs =
@@ -797,6 +800,9 @@ export class ExecutionLogger implements IExecutionLoggerService {
       ...(pii.environment !== undefined
         ? { environment: pii.environment as ExecutionEnvironment }
         : {}),
+      ...(pii.correlation !== undefined
+        ? { correlation: pii.correlation as ExecutionData['correlation'] }
+        : {}),
     }
 
     stripSpanCosts((cleanExecutionData as Record<string, unknown>).traceSpans)

apps/sim/lib/logs/execution/pii-redaction.test.ts

@@ -93,6 +93,7 @@ describe('redactPIIFromExecution', () => {
       trigger: { type: 'webhook', data: { from: 'caller@x.com' } },
       executionState: { status: 'completed', note: 'state for e@f.com' },
       environment: { variables: { CONTACT: 'admin@x.com' } },
+      correlation: { source: 'corr@x.com' },
     }
 
     const result = await redactPIIFromExecution(payload, { entityTypes: ['EMAIL_ADDRESS'] })
@@ -107,6 +108,7 @@ describe('redactPIIFromExecution', () => {
     expect((result.trigger as any).data.from).toBe('MASKED(caller@x.com)')
     expect((result.executionState as any).note).toBe('MASKED(state for e@f.com)')
     expect((result.environment as any).variables.CONTACT).toBe('MASKED(admin@x.com)')
+    expect((result.correlation as any).source).toBe('MASKED(corr@x.com)')
   })
 
   it('returns payload unchanged when there is nothing to mask', async () => {

apps/sim/lib/logs/execution/pii-redaction.ts

@@ -29,6 +29,7 @@ export interface RedactablePayload {
   trigger?: unknown
   executionState?: unknown
   environment?: unknown
+  correlation?: unknown
 }
 
 /** Keys of {@link RedactablePayload} processed by the redactor, in order. */
@@ -41,6 +42,7 @@ const REDACTABLE_KEYS: (keyof RedactablePayload)[] = [
   'trigger',
   'executionState',
   'environment',
+  'correlation',
 ]
 
 /** Trace-span fields that carry runtime content (and therefore possible PII). */