From 087bee17446d8d0e1750d6ccdc58a3e3a517ad9f Mon Sep 17 00:00:00 2001
From: Johan Haals <johan.haals@gmail.com>
Date: Fri, 12 Feb 2021 09:46:59 +0100
Subject: [PATCH] scaffolder: Pass correct logger
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: Fredrik Adelöw <freben@gmail.com>
Co-authored-by: blam<ben@blam.sh>
Co-authored-by: Patrik Oldsberg <poldsberg@gmail.com>
---
 .../scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts b/plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts
index 51260aef7d..4511a836f6 100644
--- a/plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts
+++ b/plugins/scaffolder-backend/src/scaffolder/tasks/TaskWorker.ts
@@ -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,