Flushing for execution handler (#1293)

shagun-singh-inkeep · web-flow · commit cbb7c09caa60 · 2025-12-16T13:09:48.000-05:00
* flushing

* changeset

* biome format
diff --git a/.changeset/metal-apples-taste.md b/.changeset/metal-apples-taste.md
@@ -0,0 +1,13 @@
+---
+"@inkeep/agents-run-api": patch
+"@inkeep/agents-cli": patch
+"@inkeep/agents-manage-api": patch
+"@inkeep/agents-manage-ui": patch
+"@inkeep/agents-core": patch
+"@inkeep/agents-manage-mcp": patch
+"@inkeep/agents-sdk": patch
+"@inkeep/ai-sdk-provider": patch
+"@inkeep/create-agents": patch
+---
+
+batch flushing
diff --git a/agents-run-api/src/handlers/executionHandler.ts b/agents-run-api/src/handlers/executionHandler.ts
@@ -18,6 +18,7 @@ import { executeTransfer } from '../a2a/transfer.js';
 import { extractTransferData, isTransferTask } from '../a2a/types.js';
 import { AGENT_EXECUTION_MAX_CONSECUTIVE_ERRORS } from '../constants/execution-limits';
 import dbClient from '../data/db/dbClient.js';
+import { flushBatchProcessor } from '../instrumentation.js';
 import { getLogger } from '../logger.js';
 import { agentSessionManager } from '../services/AgentSession.js';
 import { agentInitializingOp, completionOp, errorOp } from '../utils/agent-operations.js';
@@ -520,6 +521,10 @@ export class ExecutionHandler {
               throw error;
             } finally {
               span.end();
+              // Flush immediately after span ends to ensure it's sent to SignOz
+              // Use setImmediate to allow span to be processed before flushing
+              await new Promise((resolve) => setImmediate(resolve));
+              await flushBatchProcessor();
             }
           });
         }
