diff --git a/packages/runner/src/runner.ts b/packages/runner/src/runner.ts index f5244674e..e7a735df1 100644 --- a/packages/runner/src/runner.ts +++ b/packages/runner/src/runner.ts @@ -300,7 +300,7 @@ export class Runner implements IComponent { if (timeout) { this.monitoringMessageReplyTimeout = setTimeout(async () => { - this.logger.warn("Monitoring Reply Timeout. Connected"); + this.logger.warn("Monitoring Reply Timeout"); await this.handleDisconnect(); }, timeout); @@ -324,7 +324,7 @@ export class Runner implements IComponent { try { await this.hostClient.disconnect(!this.connected); - await defer(5000); + await defer(10000); } catch (e) { this.logger.error("Disconnect failed"); } @@ -405,18 +405,18 @@ export class Runner implements IComponent { try { this.logger.debug("connecting..."); - await promiseTimeout(this.hostClient.init(this.instanceId), 5000); + await promiseTimeout(this.hostClient.init(this.instanceId), 10000); this.logger.debug("connected"); this.connected = true; - this.hostClient.inputStream.pipe(this.logFile!); + //this.hostClient.inputStream.pipe(this.logFile!); await this.handleMonitoringRequest({ monitoringRate: 1 }); } catch (e) { this.connected = false; this.logger.warn("Can't connect to Host", e); - await defer(5000); + await defer(10000); return await this.premain(); }