scaffolder: Pass correct logger

Co-authored-by: Fredrik Adelöw <freben@gmail.com>
Co-authored-by: blam<ben@blam.sh>
Co-authored-by: Patrik Oldsberg <poldsberg@gmail.com>
This commit is contained in:
Johan Haals
2021-02-12 09:46:59 +01:00
parent d4c77f9316
commit 087bee1744
@@ -76,9 +76,11 @@ export class TaskWorker {
});
const stream = new PassThrough();
stream.on('data', data => {
stream.on('data', async data => {
const message = data.toString().trim();
if (message?.length > 1) task.emitLog(message, metadata);
if (message?.length > 1) {
await task.emitLog(message, metadata);
}
});
taskLogger.add(new winston.transports.Stream({ stream }));
@@ -112,7 +114,7 @@ export class TaskWorker {
const stepOutputs: { [name: string]: JsonValue } = {};
await action.handler({
logger,
logger: taskLogger,
logStream: stream,
parameters,
workspacePath,