From 9e220eca4545982df83ffcaa66a9b050a3d6f24e Mon Sep 17 00:00:00 2001
From: Elizabeth Hunt <me@liz.coffee>
Date: Sun, 20 Jul 2025 16:03:44 -0700
Subject: Fixes silent failures

---
 worker/executor.ts | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

(limited to 'worker/executor.ts')

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 } }),
-- 
cgit v1.2.3-70-g09d2