diff options
| author | Elizabeth Hunt <me@liz.coffee> | 2025-07-26 15:15:56 -0700 |
|---|---|---|
| committer | Elizabeth Hunt <me@liz.coffee> | 2025-07-26 15:16:09 -0700 |
| commit | 8a0c5f5cae2d6cdc66315172d7ffdffc8954ffaa (patch) | |
| tree | aaf3c74620ede2c0beab6d5a0576848d038721ff /worker | |
| parent | b1efe258974f93616c98485f2bcfb8b999f0e4ad (diff) | |
| download | ci-8a0c5f5cae2d6cdc66315172d7ffdffc8954ffaa.tar.gz ci-8a0c5f5cae2d6cdc66315172d7ffdffc8954ffaa.zip | |
Uses correct subpackage for server in ci and streams stdout and stderr during ci builds
Diffstat (limited to 'worker')
| -rw-r--r-- | worker/executor.ts | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/worker/executor.ts b/worker/executor.ts index fe3a688..2640f39 100644 --- a/worker/executor.ts +++ b/worker/executor.ts @@ -25,10 +25,11 @@ export const executeJob = (tJob: ITraceable<Job, LogMetricTraceSupplier>) => { 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 })), + .flatMapAsync((args) => + getStdout(tJob.move(tJob.get().type), { env: args, streamTraceable: ['stdout', 'stderr'] }), + ), ) .flatMapAsync(TraceUtil.promiseify(TraceUtil.traceResultingEither(metric))) - .peek(TraceUtil.promiseify((t) => t.traceScope(() => LogLevel.DEBUG).trace.trace(JSON.stringify(t.get())))) .get(); }; // -- </job.exectuor> -- |