1 files changed, 23 insertions, 23 deletions

diff --git a/src/server/DashSession/Session/agents/server_worker.ts b/src/server/DashSession/Session/agents/server_worker.ts
index d8b3ee80b..85e1b31d6 100644
--- a/src/server/DashSession/Session/agents/server_worker.ts
+++ b/src/server/DashSession/Session/agents/server_worker.ts
@@ -1,10 +1,10 @@
-import cluster from "cluster";
-import { green, red, white, yellow } from "colors";
-import { get } from "request-promise";
-import { ExitHandler } from "./applied_session_agent";
-import { Monitor } from "./monitor";
-import IPCMessageReceiver from "./process_message_router";
-import { ErrorLike, manage } from "./promisified_ipc_manager";
+import cluster from 'cluster';
+import { green, red, white, yellow } from 'colors';
+import { get } from 'request-promise';
+import { ExitHandler } from './applied_session_agent';
+import { Monitor } from './monitor';
+import IPCMessageReceiver from './process_message_router';
+import { ErrorLike, manage } from './promisified_ipc_manager';
 
 /**
  * Effectively, each worker repairs the connection to the server by reintroducing a consistent state
@@ -23,18 +23,17 @@ export class ServerWorker extends IPCMessageReceiver {
     private isInitialized = false;
     public static Create(work: Function) {
         if (cluster.isPrimary) {
-            console.error(red("cannot create a worker on the monitor process."));
+            console.error(red('cannot create a worker on the monitor process.'));
             process.exit(1);
         } else if (++ServerWorker.count > 1) {
-            ServerWorker.IPCManager.emit("kill", {
-                reason: "cannot create more than one worker on a given worker process.",
+            ServerWorker.IPCManager.emit('kill', {
+                reason: 'cannot create more than one worker on a given worker process.',
                 graceful: false,
-                errorCode: 1
+                errorCode: 1,
             });
             process.exit(1);
-        } else {
-            return new ServerWorker(work);
         }
+        return new ServerWorker(work);
     }
 
     /**
@@ -48,7 +47,7 @@ export class ServerWorker extends IPCMessageReceiver {
      * server worker (child process). This will also kill
      * this process (child process).
      */
-    public killSession = (reason: string, graceful = true, errorCode = 0) => this.emit<never>("kill", { reason, graceful, errorCode });
+    public killSession = (reason: string, graceful = true, errorCode = 0) => this.emit<never>('kill', { reason, graceful, errorCode });
 
     /**
      * A convenience wrapper to tell the session monitor (parent process)
@@ -60,7 +59,7 @@ export class ServerWorker extends IPCMessageReceiver {
         super();
         this.configureInternalHandlers();
         ServerWorker.IPCManager = manage(process, this.handlers);
-        this.lifecycleNotification(green(`initializing process... ${white(`[${process.execPath} ${process.execArgv.join(" ")}]`)}`));
+        this.lifecycleNotification(green(`initializing process... ${white(`[${process.execPath} ${process.execArgv.join(' ')}]`)}`));
 
         const { pollingRoute, serverPort, pollingIntervalSeconds, pollingFailureTolerance } = process.env;
         this.serverPort = Number(serverPort);
@@ -78,8 +77,10 @@ export class ServerWorker extends IPCMessageReceiver {
      */
     protected configureInternalHandlers = () => {
         // updates the local values of variables to the those sent from master
-        this.on("updatePollingInterval", ({ newPollingIntervalSeconds }) => this.pollingIntervalSeconds = newPollingIntervalSeconds);
-        this.on("manualExit", async ({ isSessionEnd }) => {
+        this.on('updatePollingInterval', ({ newPollingIntervalSeconds }) => {
+            this.pollingIntervalSeconds = newPollingIntervalSeconds;
+        });
+        this.on('manualExit', async ({ isSessionEnd }) => {
             await ServerWorker.IPCManager.destroy();
             await this.executeExitHandlers(isSessionEnd);
             process.exit(0);
@@ -91,7 +92,7 @@ export class ServerWorker extends IPCMessageReceiver {
             const appropriateError = reason instanceof Error ? reason : new Error(`unhandled rejection: ${reason}`);
             this.proactiveUnplannedExit(appropriateError);
         });
-    }
+    };
 
     /**
      * Execute the list of functions registered to be called
@@ -102,7 +103,7 @@ export class ServerWorker extends IPCMessageReceiver {
     /**
      * Notify master thread (which will log update in the console) of initialization via IPC.
      */
-    public lifecycleNotification = (event: string) => this.emit("lifecycle", { event });
+    public lifecycleNotification = (event: string) => this.emit('lifecycle', { event });
 
     /**
      * Called whenever the process has a reason to terminate, either through an uncaught exception
@@ -120,11 +121,11 @@ export class ServerWorker extends IPCMessageReceiver {
         this.lifecycleNotification(red(error.message));
         await ServerWorker.IPCManager.destroy();
         process.exit(1);
-    }
+    };
 
     /**
      * This monitors the health of the server by submitting a get request to whatever port / route specified
-     * by the configuration every n seconds, where n is also given by the configuration. 
+     * by the configuration every n seconds, where n is also given by the configuration.
      */
     private pollServer = async (): Promise<void> => {
         await new Promise<void>(resolve => {
@@ -156,6 +157,5 @@ export class ServerWorker extends IPCMessageReceiver {
         });
         // controlled, asynchronous infinite recursion achieves a persistent poll that does not submit a new request until the previous has completed
         this.pollServer();
-    }
-
+    };
 }