mirror of
https://github.com/farcasclaudiu/Flowise.git
synced 2026-06-28 23:01:09 +03:00
Merge pull request #1042 from marcklingen/langfuse-params
Remove unnecessary Langfuse inputs
This commit is contained in:
@@ -238,9 +238,6 @@ export const additionalCallbacks = async (nodeData: INodeData, options: ICommonO
|
|||||||
})
|
})
|
||||||
callbacks.push(tracer)
|
callbacks.push(tracer)
|
||||||
} else if (provider === 'langFuse') {
|
} else if (provider === 'langFuse') {
|
||||||
const flushAt = analytic[provider].flushAt as string
|
|
||||||
const flushInterval = analytic[provider].flushInterval as string
|
|
||||||
const requestTimeout = analytic[provider].requestTimeout as string
|
|
||||||
const release = analytic[provider].release as string
|
const release = analytic[provider].release as string
|
||||||
|
|
||||||
const langFuseSecretKey = getCredentialParam('langFuseSecretKey', credentialData, nodeData)
|
const langFuseSecretKey = getCredentialParam('langFuseSecretKey', credentialData, nodeData)
|
||||||
@@ -252,9 +249,6 @@ export const additionalCallbacks = async (nodeData: INodeData, options: ICommonO
|
|||||||
publicKey: langFusePublicKey,
|
publicKey: langFusePublicKey,
|
||||||
baseUrl: langFuseEndpoint ?? 'https://cloud.langfuse.com'
|
baseUrl: langFuseEndpoint ?? 'https://cloud.langfuse.com'
|
||||||
}
|
}
|
||||||
if (flushAt) langFuseOptions.flushAt = parseInt(flushAt, 10)
|
|
||||||
if (flushInterval) langFuseOptions.flushInterval = parseInt(flushInterval, 10)
|
|
||||||
if (requestTimeout) langFuseOptions.requestTimeout = parseInt(requestTimeout, 10)
|
|
||||||
if (release) langFuseOptions.release = release
|
if (release) langFuseOptions.release = release
|
||||||
|
|
||||||
const handler = new CallbackHandler(langFuseOptions)
|
const handler = new CallbackHandler(langFuseOptions)
|
||||||
|
|||||||
@@ -81,27 +81,6 @@ const analyticProviders = [
|
|||||||
type: 'credential',
|
type: 'credential',
|
||||||
credentialNames: ['langfuseApi']
|
credentialNames: ['langfuseApi']
|
||||||
},
|
},
|
||||||
{
|
|
||||||
label: 'Flush At',
|
|
||||||
name: 'flushAt',
|
|
||||||
type: 'number',
|
|
||||||
optional: true,
|
|
||||||
description: 'Number of queued requests'
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Flush Interval',
|
|
||||||
name: 'flushInterval',
|
|
||||||
type: 'number',
|
|
||||||
optional: true,
|
|
||||||
description: 'Interval in ms to flush requests'
|
|
||||||
},
|
|
||||||
{
|
|
||||||
label: 'Request Timeout',
|
|
||||||
name: 'requestTimeout',
|
|
||||||
type: 'number',
|
|
||||||
optional: true,
|
|
||||||
description: 'Timeout in ms for requests'
|
|
||||||
},
|
|
||||||
{
|
{
|
||||||
label: 'Release',
|
label: 'Release',
|
||||||
name: 'release',
|
name: 'release',
|
||||||
|
|||||||
Reference in New Issue
Block a user