We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 1a0478d commit 00e8963Copy full SHA for 00e8963
1 file changed
src/sync/seen-cache.ts
@@ -1,6 +1,7 @@
1
import type { Postgres } from "@query-doctor/core";
2
import { QueryHash, RawRecentQuery, RecentQuery } from "../sql/recent-query.ts";
3
import { fingerprint } from "@libpg-query/parser";
4
+import { log } from "../log.ts";
5
6
interface CacheEntry {
7
firstSeen: number;
@@ -50,7 +51,13 @@ export class QueryCache {
50
51
// TODO: bound the concurrency
52
return await Promise.all(rawQueries.map(async (rawQuery) => {
53
const key = await this.store(rawQuery);
- return RecentQuery.analyze(rawQuery, key, this.getFirstSeen(key));
54
+ try {
55
+ return await RecentQuery.analyze(rawQuery, key, this.getFirstSeen(key));
56
+ } catch (error) {
57
+ log.error(`Failed to analyze query ${rawQuery.query}`, "query-cache")
58
+ console.error(error)
59
+ throw error;
60
+ }
61
}));
62
}
63
0 commit comments