( payload: ScheduleExecutionPayload )
| 115 | } |
| 116 | |
| 117 | export function buildScheduleCorrelation( |
| 118 | payload: ScheduleExecutionPayload |
| 119 | ): AsyncExecutionCorrelation { |
| 120 | const executionId = payload.executionId || generateId() |
| 121 | const requestId = payload.requestId || payload.correlation?.requestId || executionId.slice(0, 8) |
| 122 | |
| 123 | return { |
| 124 | executionId, |
| 125 | requestId, |
| 126 | source: 'schedule', |
| 127 | workflowId: payload.workflowId, |
| 128 | scheduleId: payload.scheduleId, |
| 129 | triggerType: payload.correlation?.triggerType || 'schedule', |
| 130 | scheduledFor: payload.scheduledFor || payload.correlation?.scheduledFor, |
| 131 | } |
| 132 | } |
| 133 | |
| 134 | async function applyScheduleUpdate( |
| 135 | scheduleId: string, |
no test coverage detected