summaryrefslogtreecommitdiff
path: root/worker/executor.ts
diff options
context:
space:
mode:
authorElizabeth Hunt <me@liz.coffee>2025-07-01 10:49:40 -0700
committerElizabeth Hunt <me@liz.coffee>2025-07-01 10:49:40 -0700
commit7d2c0a4aedad3c5e8a81bd19f4417aa4f9fb8360 (patch)
treec4bba5f176774ce337d532e9b47e16ef5a98b337 /worker/executor.ts
parentf556523d908ed2ae836fe077f11c5a1b724d459a (diff)
downloadci-7d2c0a4aedad3c5e8a81bd19f4417aa4f9fb8360.tar.gz
ci-7d2c0a4aedad3c5e8a81bd19f4417aa4f9fb8360.zip
Use correct fetch code props
Diffstat (limited to 'worker/executor.ts')
-rw-r--r--worker/executor.ts3
1 files changed, 2 insertions, 1 deletions
diff --git a/worker/executor.ts b/worker/executor.ts
index bfcbc37..47b337c 100644
--- a/worker/executor.ts
+++ b/worker/executor.ts
@@ -18,7 +18,7 @@ export const executeJob = (tJob: ITraceable<Job, LogMetricTraceSupplier>) => {
const metric = jobTypeMetric(tJob.get().type);
return tJob
.flatMap(TraceUtil.withMetricTrace(metric))
- .peek((tJob) => tJob.trace.trace(`let's do this little job ok!! ${tJob.get()}`))
+ .peek((tJob) => tJob.trace.trace(`let's do this little job ok!! ${JSON.stringify(tJob.get())}`))
.map((tJob) =>
validateExecutionEntries(tJob.get().arguments)
.mapLeft((badEntries) => {
@@ -28,6 +28,7 @@ export const executeJob = (tJob: ITraceable<Job, LogMetricTraceSupplier>) => {
.flatMapAsync((args) => getStdout(tJob.move(tJob.get().type), { env: args })),
)
.flatMapAsync(TraceUtil.promiseify(TraceUtil.traceResultingEither(metric)))
+ .peek(TraceUtil.promiseify(t => t.traceScope(() => LogLevel.DEBUG).trace.trace(JSON.stringify(t.get()))))
.get();
};
// -- </job.exectuor> --