CERBERUS/LibreChat
1
0
Fork 0
mirror of https://github.com/danny-avila/LibreChat.git synced 2026-07-11 08:43:48 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(langfuse): satisfy api typecheck

Browse source
This commit is contained in:
Ravi Kumar L 2026-06-26 01:23:00 +02:00
parent 4a43116c59
commit e46ce63c4b
2 changed files with 13 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

4
packages/api/src/agents/__tests__/run-summarization.test.ts
View file

@ -1306,7 +1306,9 @@ describe('Langfuse run config', () => {
} as AppConfig,
});
expect(callArgs.langfuse?.baseUrl).toBe('http://collector-from-env:4318/tenant/eu');
expect((callArgs.langfuse as { baseUrl?: string } | undefined)?.baseUrl).toBe(
'http://collector-from-env:4318/tenant/eu',
);
});
it.each(['1', 'yes', 'on'])(

15
packages/api/src/langfuse/config.ts
View file

@ -101,24 +101,29 @@ export function buildLangfuseConfig({
normalizeString(fanout?.collectorUrl) ??
normalizeString(process.env.LANGFUSE_FANOUT_COLLECTOR_URL);
const tenantDestination = resolveLangfuseTenantDestination(config?.baseUrl);
const tenantExportDestination = hasTenantCredentials ? tenantDestination : undefined;
const tenantExportCollectorUrl = fanoutCollectorUrl;
const tenantExportEnabled =
hasTenantCredentials &&
fanoutEnabled &&
isLangfuseTenantExportEnabled() &&
Boolean(tenantDestination) &&
Boolean(fanoutCollectorUrl);
tenantExportDestination != null &&
tenantExportCollectorUrl != null;
if (tenantExportEnabled) {
if (tenantExportEnabled && tenantExportDestination && tenantExportCollectorUrl) {
langfuse.publicKey = publicKey;
langfuse.secretKey = secretKey;
langfuse.baseUrl = appendPath(fanoutCollectorUrl, `/tenant/${tenantDestination.key}`);
langfuse.baseUrl = appendPath(
tenantExportCollectorUrl,
`/tenant/${tenantExportDestination.key}`,
);
// TODO: Add support in @librechat/agents for Langfuse additionalHeaders and
// route by headers if we need multiple tenant Langfuse exports for one run.
// The destination-scoped URL is the current app-to-gateway routing contract.
langfuse.librechatTraceAttributes = {
...(langfuse.librechatTraceAttributes ?? {}),
[TENANT_EXPORT_ATTRIBUTE]: 'true',
[TENANT_DESTINATION_ATTRIBUTE]: tenantDestination?.key,
[TENANT_DESTINATION_ATTRIBUTE]: tenantExportDestination.key,
};
} else if (fanoutEnabled && fanoutCollectorUrl) {
langfuse.baseUrl = fanoutCollectorUrl;