diff options
| author | Elizabeth Hunt <me@liz.coffee> | 2025-07-26 17:39:44 -0700 |
|---|---|---|
| committer | Elizabeth Hunt <me@liz.coffee> | 2025-07-26 18:09:32 -0700 |
| commit | 9ee3bf3345b006a745b2ee28fee3613819011796 (patch) | |
| tree | 5e92342d75d0a72102f320b85363cdbb36f3de43 /worker/executor.ts | |
| parent | df1a7eec824d9e9d99c58b1f7792c8f384955273 (diff) | |
| download | ci-9ee3bf3345b006a745b2ee28fee3613819011796.tar.gz ci-9ee3bf3345b006a745b2ee28fee3613819011796.zip | |
Adds session-level storage for bw cli
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)}`)) |