Skip to content
Snippets Groups Projects
Commit ec0bb682 authored by thucpn's avatar thucpn
Browse files

Merge branch 'main' into tp/llamaindex-server-package

parents 033c49d0 5189b446
Branches
No related tags found
No related merge requests found
---
"@llamaindex/cloud": patch
"@llamaindex/community": patch
"@llamaindex/core": patch
"@llamaindex/readers": patch
---
fix: add retry handling logic to parser reader and fix lint issues
...@@ -50,6 +50,9 @@ export default tseslint.config( ...@@ -50,6 +50,9 @@ export default tseslint.config(
"**/lib/*", "**/lib/*",
"**/deps/**", "**/deps/**",
"**/.next/**", "**/.next/**",
"**/.source/**", // Ignore .source directories
"!.git", // Don't ignore .git directory
"**/.*", // Ignore all dot files and directories
"**/node_modules/**", "**/node_modules/**",
"**/build/**", "**/build/**",
"**/.docusaurus/**", "**/.docusaurus/**",
......
...@@ -46,5 +46,8 @@ ...@@ -46,5 +46,8 @@
"*.{json,md,yml}": [ "*.{json,md,yml}": [
"prettier --write" "prettier --write"
] ]
},
"dependencies": {
"p-retry": "^6.2.1"
} }
} }
This diff is collapsed.
...@@ -24,6 +24,7 @@ import { ...@@ -24,6 +24,7 @@ import {
} from "./utils"; } from "./utils";
export class AmazonProvider extends Provider<ConverseStreamOutput> { export class AmazonProvider extends Provider<ConverseStreamOutput> {
// eslint-disable-next-line @typescript-eslint/no-explicit-any
getResultFromResponse(response: Record<string, any>): ConverseResponse { getResultFromResponse(response: Record<string, any>): ConverseResponse {
return JSON.parse(toUtf8(response.body)); return JSON.parse(toUtf8(response.body));
} }
...@@ -52,7 +53,7 @@ export class AmazonProvider extends Provider<ConverseStreamOutput> { ...@@ -52,7 +53,7 @@ export class AmazonProvider extends Provider<ConverseStreamOutput> {
} }
getTextFromStreamResponse(response: ResponseStream): string { getTextFromStreamResponse(response: ResponseStream): string {
let event: ConverseStreamOutput | undefined = const event: ConverseStreamOutput | undefined =
this.getStreamingEventResponse(response); this.getStreamingEventResponse(response);
if (!event || !event.contentBlockDelta) return ""; if (!event || !event.contentBlockDelta) return "";
const delta: ContentBlockDelta | undefined = event.contentBlockDelta.delta; const delta: ContentBlockDelta | undefined = event.contentBlockDelta.delta;
......
...@@ -56,7 +56,7 @@ export const mapImageContent = (imageUrl: string): ImageBlock => { ...@@ -56,7 +56,7 @@ export const mapImageContent = (imageUrl: string): ImageBlock => {
mimeType as keyof typeof ACCEPTED_IMAGE_MIME_TYPE_FORMAT_MAP mimeType as keyof typeof ACCEPTED_IMAGE_MIME_TYPE_FORMAT_MAP
], ],
// @ts-ignore: there's a mistake in the "@aws-sdk/client-bedrock-runtime" compared to the actual api // @ts-expect-error: there's a mistake in the "@aws-sdk/client-bedrock-runtime" compared to the actual api
source: { bytes: data }, source: { bytes: data },
}; };
}; };
......
...@@ -20,4 +20,5 @@ export const DEFAULT_NAMESPACE = "docstore"; ...@@ -20,4 +20,5 @@ export const DEFAULT_NAMESPACE = "docstore";
//#region llama cloud //#region llama cloud
export const DEFAULT_PROJECT_NAME = "Default"; export const DEFAULT_PROJECT_NAME = "Default";
export const DEFAULT_BASE_URL = "https://api.cloud.llamaindex.ai"; export const DEFAULT_BASE_URL = "https://api.cloud.llamaindex.ai";
export const DEFAULT_EU_BASE_URL = "https://api.cloud.eu.llamaindex.ai";
//#endregion //#endregion
...@@ -60,7 +60,7 @@ export class SimpleCosmosDBReader implements BaseReader { ...@@ -60,7 +60,7 @@ export class SimpleCosmosDBReader implements BaseReader {
const metadataFields = config.metadataFields; const metadataFields = config.metadataFields;
try { try {
let res = await container.items.query(query).fetchAll(); const res = await container.items.query(query).fetchAll();
const documents: Document[] = []; const documents: Document[] = [];
for (const item of res.resources) { for (const item of res.resources) {
......
This diff is collapsed.
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment