Skip to content
Closed
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 11 additions & 4 deletions ingesters/src/generateEmbeddings.ts
Original file line number Diff line number Diff line change
Expand Up @@ -184,6 +184,7 @@ async function ingestSource(source: DocumentSource): Promise<void> {
* Main function to run the ingestion process
*/
async function main() {
let exitCode = 0;
try {
// Prompt user for target
const target = await promptForTarget();
Expand All @@ -201,12 +202,18 @@ async function main() {

logger.info('All specified ingestion processes completed successfully.');
} catch (error) {
exitCode = 1;
logger.error('An error occurred during the ingestion process:', error);
} finally {
// Clean up resources
if (vectorStore) {
await vectorStore.close();
process.exit(0);
// Clean up resources and exit deterministically
try {
if (vectorStore) {
await vectorStore.close();
}
} catch (cleanupError) {
logger.warn('Error while cleaning up resources:', cleanupError);
} finally {
process.exit(exitCode);
}
}
}
Expand Down