diff options
Diffstat (limited to 'worker/executor.ts')
| -rw-r--r-- | worker/executor.ts | 3 |
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> -- |