diff options
Diffstat (limited to 'worker/executor.ts')
| -rw-r--r-- | worker/executor.ts | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/worker/executor.ts b/worker/executor.ts index 2640f39..3cd2cbc 100644 --- a/worker/executor.ts +++ b/worker/executor.ts @@ -44,7 +44,7 @@ export const executePipeline = ( .flatMap(TraceUtil.withFunctionTrace(executePipeline)) .flatMap(TraceUtil.withMetricTrace(pipelinesMetric)) .map(async (_tPipeline): Promise<IEither<Error, void>> => { - for (const [i, serialStage] of tPipeline.get().serialJobs.entries()) { + for (const [i, serialStage] of _tPipeline.get().serialJobs.entries()) { const tPipeline = _tPipeline.traceScope(() => `Stage = ${i}`); const parallelJobs = tPipeline .peek((t) => t.trace.trace(`do your best little stage :> ${JSON.stringify(serialStage)}`)) |