statsd fix attempt #1

hicommonwealth · Jul 26, 2024 · 759ac65 · 759ac65
1 parent ce81b7e
commit 759ac65
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/libs/core/src/ports/port.ts b/libs/core/src/ports/port.ts
@@ -57,6 +57,10 @@ const disposeAndExit = async (
   // don't kill process when errors are caught in production
   if (code === 'ERROR' && config.NODE_ENV === 'production' && !forceExit)
     return;
+  else if (code === 'ERROR' && config.NODE_ENV === 'production' && forceExit) {
+    // sleep for 1 second to allow stat metrics to flush
+    await new Promise((resolve) => setTimeout(resolve, 1_000));
+  }
 
   // call disposers
   await Promise.all(disposers.map((disposer) => disposer()));

diff --git a/packages/commonwealth/scripts/archive-outbox.ts b/packages/commonwealth/scripts/archive-outbox.ts
@@ -207,10 +207,11 @@ async function main() {
 if (import.meta.url.endsWith(process.argv[1])) {
   main()
     .then(async () => {
-      stats(HotShotsStats()).increment('cw.scheduler.archive-outbox');
+      stats(HotShotsStats()).on('cw.scheduler.archive-outbox');
       await dispose()('EXIT', true);
     })
     .catch(async (err) => {
+      stats(HotShotsStats()).off('cw.scheduler.archive-outbox');
       log.fatal('Failed to archive outbox child partitions to S3', err);
       await dispose()('ERROR', true);
     });