|
@@ -67,9 +67,7 @@ async function indexDestination(
|
|
|
reindex = false,
|
|
reindex = false,
|
|
|
batchSize = 100,
|
|
batchSize = 100,
|
|
|
): Promise<IndexResult> {
|
|
): Promise<IndexResult> {
|
|
|
- console.log(
|
|
|
|
|
- `Worker: Starting indexing for ${dataset} at ${destination}`,
|
|
|
|
|
- );
|
|
|
|
|
|
|
+ console.log(`Worker: Starting indexing for ${dataset} at ${destination}`);
|
|
|
console.log(`Worker: Database path: ${dbPath}`);
|
|
console.log(`Worker: Database path: ${dbPath}`);
|
|
|
console.log(`Worker: Reindex: ${reindex}, Batch size: ${batchSize}`);
|
|
console.log(`Worker: Reindex: ${reindex}, Batch size: ${batchSize}`);
|
|
|
|
|
|
|
@@ -155,9 +153,7 @@ async function indexDestination(
|
|
|
);
|
|
);
|
|
|
}
|
|
}
|
|
|
} catch (error) {
|
|
} catch (error) {
|
|
|
- console.error(
|
|
|
|
|
- `Worker: Failed to index file ${filePath}: ${error}`,
|
|
|
|
|
- );
|
|
|
|
|
|
|
+ console.error(`Worker: Failed to index file ${filePath}: ${error}`);
|
|
|
errors++;
|
|
errors++;
|
|
|
}
|
|
}
|
|
|
}),
|
|
}),
|