[Fix] Runner log

bdd/step-definitions/e2e/cli.ts

@@ -515,6 +515,7 @@ When("I deploy sequence {string}", async function (
 ) {
     const seqPath = `../packages/${sequenceName}`;
     const res = this.cliResources;
+
     res.stdio = await getStreamsFromSpawn("/usr/bin/env", [
         ...si,
         "seq",
@@ -528,8 +529,10 @@ Then("I should see error message: {string}", async function (
     errorMessage: string
 ) {
     const res = this.cliResources;
+
     if (res.stdio) {
         const errorMessageRegex = new RegExp(errorMessage);
+
         assert.match(res.stdio[1], errorMessageRegex);
     } else {
         assert.fail("cliResources or stdio is undefined");
@@ -541,9 +544,11 @@ Then("I should see exitCode: {string}", async function (
     exitCode: string
 ) {
     const res = this.cliResources;
+
     if (res && res.stdio) {
         const exitCodeRegex = new RegExp(exitCode);
         const receivedExitCode: string = res.stdio[2].toString();
+
         assert.match(
             receivedExitCode,
             exitCodeRegex,
@@ -558,13 +563,15 @@ Then(
     "Instance info should contain provided parameters in {string}",
     async function (this: CustomWorld, file: string) {
         const res = this.cliResources;
+
         if (res.stdio) {
             try {
                 const expected = await fs.promises
                     .readFile(`../bdd/data/${file}`, "utf8")
                     .then(JSON.parse);
 
                 const received = res.stdio[0] ? JSON.parse(res.stdio[0]) : null;
+
                 if (process.env.SCRAMJET_TEST_LOG) {
                     logger.debug("received.appConfig:", received.appConfig);
                     logger.debug("expected.appConfig:", expected.appConfig);

packages/runner/src/runner.ts

@@ -141,7 +141,7 @@ export class Runner<X extends AppConfig> implements IComponent {
         });
 
         this.outputDataStream = new DataStream({ highWaterMark: 0 }).catch((e: any) => {
-            this.logger.error("Error during input data stream", e);
+            this.logger.error("Error during output data stream", e);
 
             throw e;
         });