diff --git a/packages/server/src/services/assistants/index.ts b/packages/server/src/services/assistants/index.ts index 976d2d7dc88..8d635ddeab1 100644 --- a/packages/server/src/services/assistants/index.ts +++ b/packages/server/src/services/assistants/index.ts @@ -112,7 +112,7 @@ const createAssistant = async (requestBody: any): Promise => { version: await getAppVersion(), assistantId: dbResponse.id }) - appServer.metricsProvider.incrementCounter(FLOWISE_METRIC_COUNTERS.ASSISTANT_CREATED, { status: FLOWISE_COUNTER_STATUS.SUCCESS }) + appServer.metricsProvider?.incrementCounter(FLOWISE_METRIC_COUNTERS.ASSISTANT_CREATED, { status: FLOWISE_COUNTER_STATUS.SUCCESS }) return dbResponse } catch (error) { throw new InternalFlowiseError( diff --git a/packages/server/src/services/chatflows/index.ts b/packages/server/src/services/chatflows/index.ts index 6aed7e885e7..7c78b138195 100644 --- a/packages/server/src/services/chatflows/index.ts +++ b/packages/server/src/services/chatflows/index.ts @@ -192,7 +192,7 @@ const saveChatflow = async (newChatFlow: ChatFlow): Promise => { chatflowId: dbResponse.id, flowGraph: getTelemetryFlowObj(JSON.parse(dbResponse.flowData)?.nodes, JSON.parse(dbResponse.flowData)?.edges) }) - appServer.metricsProvider.incrementCounter( + appServer.metricsProvider?.incrementCounter( dbResponse?.type === 'MULTIAGENT' ? FLOWISE_METRIC_COUNTERS.AGENTFLOW_CREATED : FLOWISE_METRIC_COUNTERS.CHATFLOW_CREATED, { status: FLOWISE_COUNTER_STATUS.SUCCESS } ) diff --git a/packages/server/src/services/documentstore/index.ts b/packages/server/src/services/documentstore/index.ts index 4bf07e8ff3d..a8b69ac55c0 100644 --- a/packages/server/src/services/documentstore/index.ts +++ b/packages/server/src/services/documentstore/index.ts @@ -996,7 +996,7 @@ const _insertIntoVectorStoreWorkerThread = async (data: ICommonObject) => { type: ChatType.INTERNAL, flowGraph: omit(indexResult['result'], ['totalKeys', 'addedDocs']) }) - appServer.metricsProvider.incrementCounter(FLOWISE_METRIC_COUNTERS.VECTORSTORE_UPSERT, { status: FLOWISE_COUNTER_STATUS.SUCCESS }) + appServer.metricsProvider?.incrementCounter(FLOWISE_METRIC_COUNTERS.VECTORSTORE_UPSERT, { status: FLOWISE_COUNTER_STATUS.SUCCESS }) entity.status = DocumentStoreStatus.UPSERTED await appServer.AppDataSource.getRepository(DocumentStore).save(entity) diff --git a/packages/server/src/services/tools/index.ts b/packages/server/src/services/tools/index.ts index 1f1fac59101..1825e464a38 100644 --- a/packages/server/src/services/tools/index.ts +++ b/packages/server/src/services/tools/index.ts @@ -18,7 +18,7 @@ const createTool = async (requestBody: any): Promise => { toolId: dbResponse.id, toolName: dbResponse.name }) - appServer.metricsProvider.incrementCounter(FLOWISE_METRIC_COUNTERS.TOOL_CREATED, { status: FLOWISE_COUNTER_STATUS.SUCCESS }) + appServer.metricsProvider?.incrementCounter(FLOWISE_METRIC_COUNTERS.TOOL_CREATED, { status: FLOWISE_COUNTER_STATUS.SUCCESS }) return dbResponse } catch (error) { throw new InternalFlowiseError(StatusCodes.INTERNAL_SERVER_ERROR, `Error: toolsService.createTool - ${getErrorMessage(error)}`) diff --git a/packages/server/src/utils/buildChatflow.ts b/packages/server/src/utils/buildChatflow.ts index fb271f7abc2..b3a7e906c0f 100644 --- a/packages/server/src/utils/buildChatflow.ts +++ b/packages/server/src/utils/buildChatflow.ts @@ -494,7 +494,7 @@ export const utilBuildChatflow = async (req: Request, isInternal: boolean = fals flowGraph: getTelemetryFlowObj(nodes, edges) }) - appServer.metricsProvider.incrementCounter( + appServer.metricsProvider?.incrementCounter( isInternal ? FLOWISE_METRIC_COUNTERS.CHATFLOW_PREDICTION_INTERNAL : FLOWISE_METRIC_COUNTERS.CHATFLOW_PREDICTION_EXTERNAL, { status: FLOWISE_COUNTER_STATUS.SUCCESS } ) @@ -512,7 +512,7 @@ export const utilBuildChatflow = async (req: Request, isInternal: boolean = fals return result } catch (e) { - appServer.metricsProvider.incrementCounter( + appServer.metricsProvider?.incrementCounter( isInternal ? FLOWISE_METRIC_COUNTERS.CHATFLOW_PREDICTION_INTERNAL : FLOWISE_METRIC_COUNTERS.CHATFLOW_PREDICTION_EXTERNAL, { status: FLOWISE_COUNTER_STATUS.FAILURE } ) @@ -608,7 +608,7 @@ const utilBuildAgentResponse = async ( type: isInternal ? ChatType.INTERNAL : ChatType.EXTERNAL, flowGraph: getTelemetryFlowObj(nodes, edges) }) - appServer.metricsProvider.incrementCounter( + appServer.metricsProvider?.incrementCounter( isInternal ? FLOWISE_METRIC_COUNTERS.AGENTFLOW_PREDICTION_INTERNAL : FLOWISE_METRIC_COUNTERS.AGENTFLOW_PREDICTION_EXTERNAL, { status: FLOWISE_COUNTER_STATUS.SUCCESS } ) @@ -658,7 +658,7 @@ const utilBuildAgentResponse = async ( return undefined } catch (e) { logger.error('[server]: Error:', e) - appServer.metricsProvider.incrementCounter( + appServer.metricsProvider?.incrementCounter( isInternal ? FLOWISE_METRIC_COUNTERS.AGENTFLOW_PREDICTION_INTERNAL : FLOWISE_METRIC_COUNTERS.AGENTFLOW_PREDICTION_EXTERNAL, { status: FLOWISE_COUNTER_STATUS.FAILURE } ) diff --git a/packages/server/src/utils/upsertVector.ts b/packages/server/src/utils/upsertVector.ts index 62678bc9dac..8b51489726b 100644 --- a/packages/server/src/utils/upsertVector.ts +++ b/packages/server/src/utils/upsertVector.ts @@ -197,7 +197,7 @@ export const upsertVector = async (req: Request, isInternal: boolean = false) => flowGraph: getTelemetryFlowObj(nodes, edges), stopNodeId }) - appServer.metricsProvider.incrementCounter(FLOWISE_METRIC_COUNTERS.VECTORSTORE_UPSERT, { status: FLOWISE_COUNTER_STATUS.SUCCESS }) + appServer.metricsProvider?.incrementCounter(FLOWISE_METRIC_COUNTERS.VECTORSTORE_UPSERT, { status: FLOWISE_COUNTER_STATUS.SUCCESS }) return upsertedResult['result'] ?? { result: 'Successfully Upserted' } } catch (e) {