chore(release): staging to production - 2026.03.19

packages/components/nodes/agentflow/Agent/Agent.ts

@@ -557,6 +557,7 @@ class Agent_Agentflow implements INode {
             if (!model) {
                 throw new Error('Model is required')
             }
+            const modelName = modelConfig?.model ?? modelConfig?.modelName
 
             // Extract tools
             const tools = nodeData.inputs?.agentTools as ITool[]
@@ -1178,7 +1179,7 @@ class Agent_Agentflow implements INode {
 
             // End analytics tracking - pass usage metadata for token calculation
             if (analyticHandlers && llmIds) {
-                await analyticHandlers.onLLMEnd(llmIds, finalResponse, response.usage_metadata)
+                await analyticHandlers.onLLMEnd(llmIds, output, { model: modelName, provider: model })
             }
 
             // Send additional streaming events if needed

packages/components/nodes/agentflow/ConditionAgent/ConditionAgent.ts

@@ -259,6 +259,8 @@ class ConditionAgent_Agentflow implements INode {
             if (!model) {
                 throw new Error('Model is required')
             }
+            const modelName = modelConfig?.model ?? modelConfig?.modelName
+
             // Setup analytics tracing options and attach to options object for easy access
             const callbacks = await additionalCallbacks(nodeData, {
                 ...options,
@@ -387,13 +389,20 @@ class ConditionAgent_Agentflow implements INode {
             const endTime = Date.now()
             const timeDelta = endTime - startTime
 
-            // End analytics tracking - pass usage metadata for token calculation
+            // End analytics tracking (pass structured output with usage metadata)
             if (analyticHandlers && llmIds) {
-                await analyticHandlers.onLLMEnd(
-                    llmIds,
-                    typeof response.content === 'string' ? response.content : JSON.stringify(response.content),
-                    response.usage_metadata
-                )
+                const analyticsOutput: any = {
+                    content: typeof response.content === 'string' ? response.content : JSON.stringify(response.content)
+                }
+                // Include usage metadata if available
+                if (response.usage_metadata) {
+                    analyticsOutput.usageMetadata = response.usage_metadata
+                }
+                // Include response metadata (contains model name) if available
+                if (response.response_metadata) {
+                    analyticsOutput.responseMetadata = response.response_metadata
+                }
+                await analyticHandlers.onLLMEnd(llmIds, analyticsOutput, { model: modelName, provider: model })
             }
 
             let calledOutputName: string

packages/components/nodes/agentflow/LLM/LLM.ts

@@ -347,6 +347,7 @@ class LLM_Agentflow implements INode {
             if (!model) {
                 throw new Error('Model is required')
             }
+            const modelName = modelConfig?.model ?? modelConfig?.modelName
 
             // Extract memory and configuration options
             const enableMemory = nodeData.inputs?.llmEnableMemory as boolean
@@ -521,7 +522,7 @@ class LLM_Agentflow implements INode {
 
             // End analytics tracking - pass usage metadata for token calculation
             if (analyticHandlers && llmIds) {
-                await analyticHandlers.onLLMEnd(llmIds, finalResponse, response.usage_metadata)
+                await analyticHandlers.onLLMEnd(llmIds, output, { model: modelName, provider: model })
             }
 
             // Send additional streaming events if needed

packages/components/nodes/documentloaders/AAIDomains/AAIDomains.ts

@@ -286,12 +286,7 @@ class AAIDomains_DocumentLoaders implements INode {
         return docs
     }
 
-    async loadStream(
-        nodeData: INodeData,
-        _: string,
-        __: ICommonObject,
-        onBatch: (docs: IDocument[]) => Promise<void>
-    ): Promise<void> {
+    async loadStream(nodeData: INodeData, _: string, __: ICommonObject, onBatch: (docs: IDocument[]) => Promise<void>): Promise<void> {
         const textSplitter = nodeData.inputs?.textSplitter as TextSplitter
         const limit = nodeData.inputs?.limit ? Number(nodeData.inputs.limit) : undefined
         const searchTerm = nodeData.inputs?.searchTerm as string
@@ -476,7 +471,9 @@ class AAIDomainsLoader extends BaseDocumentLoader {
                         const requestedHeavy = heavyFields.filter((f) => requestedFields.has(f))
                         if (requestedHeavy.length > 0) {
                             console.warn(
-                                `[AAIDomains] Warning: Fetching heavy JSONB fields: ${requestedHeavy.join(', ')}. This may impact performance.`
+                                `[AAIDomains] Warning: Fetching heavy JSONB fields: ${requestedHeavy.join(
+                                    ', '
+                                )}. This may impact performance.`
                             )
                         }
                     } else {
@@ -500,11 +497,7 @@ class AAIDomainsLoader extends BaseDocumentLoader {
                         `
                     }
 
-                    let query = supabase
-                        .from('domains')
-                        .select(selectFields)
-                        .order('id', { ascending: true })
-                        .limit(currentPageSize)
+                    let query = supabase.from('domains').select(selectFields).order('id', { ascending: true }).limit(currentPageSize)
 
                     if (lastId) {
                         query = query.gt('id', lastId)

packages/components/src/Interface.ts

@@ -478,7 +478,7 @@ export enum FollowUpPromptProvider {
 }
 
 export type FollowUpPromptProviderConfig = {
-    [key in FollowUpPromptProvider]: {
+    [_key in FollowUpPromptProvider]: {
         credentialId: string
         modelName: string
         baseUrl: string