fix: prevent telemetry from blocking workflow updates (czlonkowski#946)

* fix: prevent telemetry from blocking workflow updates

Conceived by Romuald Członkowski - www.aiadvisors.pl/en

* chore: bump version to 2.65.2

Conceived by Romuald Członkowski - www.aiadvisors.pl/en

* test: close telemetry coverage gaps

Conceived by Romuald Członkowski - www.aiadvisors.pl/en

* fix: retry telemetry mutations from dead letter queue

Conceived by Romuald Członkowski - www.aiadvisors.pl/en

* fix: drain telemetry queues on scheduled flush

Conceived by Romuald Członkowski - www.aiadvisors.pl/en

* fix: retain unsent telemetry batches

Conceived by Romuald Członkowski - www.aiadvisors.pl/en

* refactor: remove unreachable telemetry branches

Conceived by Romuald Członkowski - www.aiadvisors.pl/en

* fix: await telemetry flush on shutdown

Conceived by Romuald Członkowski - www.aiadvisors.pl/en

Author: czlonkowski

CHANGELOG.md

@@ -7,6 +7,12 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ## [Unreleased]
 
+## [2.65.2] - 2026-07-23
+
+### Fixed
+
+- **Telemetry can no longer stall workflow mutation requests (#944).** Supabase telemetry requests now have a hard two-second deadline that aborts the underlying fetch, and best-effort delivery makes only one attempt so a failed request cannot leave retry work behind. Partial and full workflow-update handlers detach mutation telemetry explicitly, while a global flush queue serializes events, workflows, and mutations without silently dropping concurrent batches.
+
 ## [2.65.1] - 2026-07-16
 
 ### Fixed

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "n8n-mcp",
-  "version": "2.65.1",
+  "version": "2.65.2",
   "description": "Integration between n8n workflow automation and Model Context Protocol (MCP)",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

package.json

@@ -1110,7 +1110,7 @@ export async function handleUpdateWorkflow(
 
     // Track successful mutation
     if (workflowBefore) {
-      trackWorkflowMutationForFullUpdate({
+      void trackWorkflowMutationForFullUpdate({
         sessionId,
         toolName: 'n8n_update_full_workflow',
         userIntent,
@@ -1137,7 +1137,7 @@ export async function handleUpdateWorkflow(
   } catch (error) {
     // Track failed mutation
     if (workflowBefore) {
-      trackWorkflowMutationForFullUpdate({
+      void trackWorkflowMutationForFullUpdate({
         sessionId,
         toolName: 'n8n_update_full_workflow',
         userIntent,

src/mcp/handlers-n8n-manager.ts

@@ -582,7 +582,7 @@ export async function handleUpdatePartialWorkflow(
 
       // Track successful mutation
       if (workflowBefore && !input.validateOnly) {
-        trackWorkflowMutation({
+        void trackWorkflowMutation({
           sessionId,
           toolName: 'n8n_update_partial_workflow',
           userIntent: input.intent || 'Partial workflow update',
@@ -619,7 +619,7 @@ export async function handleUpdatePartialWorkflow(
     } catch (error) {
       // Track failed mutation
       if (workflowBefore && !input.validateOnly) {
-        trackWorkflowMutation({
+        void trackWorkflowMutation({
           sessionId,
           toolName: 'n8n_update_partial_workflow',
           userIntent: input.intent || 'Partial workflow update',
@@ -774,4 +774,3 @@ async function trackWorkflowMutation(data: any): Promise<void> {
     logger.debug('Telemetry tracking failed:', error);
   }
 }
-