diff options
| author | Elizabeth Hunt <me@liz.coffee> | 2025-07-20 16:03:44 -0700 |
|---|---|---|
| committer | Elizabeth Hunt <me@liz.coffee> | 2025-07-20 16:17:48 -0700 |
| commit | 9e220eca4545982df83ffcaa66a9b050a3d6f24e (patch) | |
| tree | a735fed0f50dec0083dac9284f45db73af1afea8 /worker/executor.ts | |
| parent | 2e10e9172f8528868b70886335dbbe20f932f702 (diff) | |
| download | ci-9e220eca4545982df83ffcaa66a9b050a3d6f24e.tar.gz ci-9e220eca4545982df83ffcaa66a9b050a3d6f24e.zip | |
Fixes silent failures
Diffstat (limited to 'worker/executor.ts')
| -rw-r--r-- | worker/executor.ts | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/worker/executor.ts b/worker/executor.ts index f9fbf29..fe3a688 100644 --- a/worker/executor.ts +++ b/worker/executor.ts @@ -22,7 +22,7 @@ export const executeJob = (tJob: ITraceable<Job, LogMetricTraceSupplier>) => { .map((tJob) => validateExecutionEntries(tJob.get().arguments) .mapLeft((badEntries) => { - tJob.trace.traceScope(LogLevel.ERROR).trace(badEntries.toString()); + tJob.trace.traceScope(LogLevel.ERROR).trace(JSON.stringify(badEntries)); return new Error('invalid job arguments'); }) .flatMapAsync((args) => getStdout(tJob.move(tJob.get().type), { env: args })), @@ -44,9 +44,9 @@ export const executePipeline = ( .flatMap(TraceUtil.withMetricTrace(pipelinesMetric)) .map(async (_tPipeline): Promise<IEither<Error, void>> => { for (const [i, serialStage] of tPipeline.get().serialJobs.entries()) { - const tPipeline = _tPipeline.flatMap(TraceUtil.withTrace(`Stage = ${i}`)); + const tPipeline = _tPipeline.traceScope(() => `Stage = ${i}`); const parallelJobs = tPipeline - .peek((t) => t.trace.trace(`do your best little stage :> ${serialStage}`)) + .peek((t) => t.trace.trace(`do your best little stage :> ${JSON.stringify(serialStage)}`)) .move(serialStage.parallelJobs) .coExtend((jobs) => jobs.get().map((job) => <Job>{ ...job, arguments: { ...baseEnv, ...job.arguments } }), |