Skip to content

Commit 49c40a6

Browse files
authored
Update inserter.ts
1 parent 9fab251 commit 49c40a6

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

svc/inserter.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ if (!trackedExists) {
1212

1313
await runInLoop(async function insert() {
1414
const { rows } = await db.raw(
15-
"SELECT match_seq_num, data FROM insert_queue WHERE processed = FALSE ORDER BY match_seq_num ASC LIMIT 150",
15+
"SELECT match_seq_num, data FROM insert_queue WHERE processed = FALSE ORDER BY match_seq_num ASC LIMIT 100",
1616
);
1717
if (!rows.length) {
1818
await new Promise((resolve) => setTimeout(resolve, 1000));
@@ -29,7 +29,7 @@ await runInLoop(async function insert() {
2929
redisCount("inserter_timeout");
3030
console.error('inserter timeout');
3131
process.exit(1);
32-
}, 10000);
32+
}, 6000);
3333
await Promise.all(
3434
rows.map(async (r: any) => {
3535
const match = r.data;

0 commit comments

Comments
 (0)