(traceContext = {})
| 271 | } |
| 272 | |
| 273 | function cloneTraceContext(traceContext = {}) { |
| 274 | const sourceTraceContext = traceContext || {}; |
| 275 | |
| 276 | return { |
| 277 | runId: sourceTraceContext.runId || null, |
| 278 | traceId: sourceTraceContext.traceId || null, |
| 279 | rootTraceId: sourceTraceContext.rootTraceId || null, |
| 280 | parentRunId: sourceTraceContext.parentRunId || null, |
| 281 | triggerType: sourceTraceContext.triggerType || null, |
| 282 | entityType: sourceTraceContext.entityType || null, |
| 283 | teamId: sourceTraceContext.teamId || null, |
| 284 | projectId: sourceTraceContext.projectId || null, |
| 285 | chartId: sourceTraceContext.chartId || null, |
| 286 | datasetId: sourceTraceContext.datasetId || null, |
| 287 | dataRequestId: sourceTraceContext.dataRequestId || null, |
| 288 | connectionId: sourceTraceContext.connectionId || null, |
| 289 | queueName: sourceTraceContext.queueName || null, |
| 290 | jobId: sourceTraceContext.jobId || null, |
| 291 | startedAt: hydrateDate(sourceTraceContext.startedAt), |
| 292 | nextSequence: sourceTraceContext.nextSequence || 1, |
| 293 | }; |
| 294 | } |
| 295 | |
| 296 | async function persistRun(context, values) { |
| 297 | if (!db.UpdateRun || !context.runId) { |
no test coverage detected