From 871c63b48bd958d301f709260dbb01273462da57 Mon Sep 17 00:00:00 2001
From: Hazelnoot <acomputerdog@gmail.com>
Date: Mon, 18 Nov 2024 01:24:23 -0500
Subject: [PATCH] print warning when activity processing exceeds 10 seonds

---
 packages/backend/src/queue/processors/InboxProcessorService.ts | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/packages/backend/src/queue/processors/InboxProcessorService.ts b/packages/backend/src/queue/processors/InboxProcessorService.ts
index 242c67359b..1dcce0ffc2 100644
--- a/packages/backend/src/queue/processors/InboxProcessorService.ts
+++ b/packages/backend/src/queue/processors/InboxProcessorService.ts
@@ -105,6 +105,9 @@ export class InboxProcessorService implements OnApplicationShutdown {
 			// Truncate nanoseconds to microseconds, then scale to milliseconds.
 			// 123,456,789 ns -> 123,456 us -> 123.456 ms
 			const duration = Number((endTime - startTime) / 1000n) / 1000;
+			if (duration > 10000) {
+				this.logger.warn(`Activity ${JSON.stringify(payload.id)} by "${keyId}" took ${(duration / 1000).toFixed(1)} seconds to complete`);
+			}
 
 			log.accepted = result.startsWith('ok');
 			log.duration = duration;