diff --git a/src/metrics/listener.ts b/src/metrics/listener.ts index 076e7b3e..9be1dd4e 100644 --- a/src/metrics/listener.ts +++ b/src/metrics/listener.ts @@ -74,6 +74,9 @@ export class MetricsListener { if (this.isAgentRunning) { logDebug(`Using StatsD client`); + if (this.statsDClient) { + return; + } this.statsDClient = new StatsD({ host: "127.0.0.1", closingFlushInterval: 1 }); return; @@ -99,20 +102,6 @@ export class MetricsListener { await processor.flush(); } - if (this.statsDClient !== undefined) { - logDebug(`Flushing statsD`); - - // Make sure all stats are flushed to extension - await new Promise((resolve, reject) => { - this.statsDClient?.close((error) => { - if (error !== undefined) { - reject(error); - } - resolve(); - }); - }); - this.statsDClient = undefined; - } } catch (error) { // This can fail for a variety of reasons, from the API not being reachable, // to KMS key decryption failing.