Elgato_dark/console
1
0
Fork 0
mirror of https://github.com/graphql-hive/console synced 2026-05-23 09:08:34 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Set retry limit to 3 for ClickHouse Cloud (#675)

Browse source
This commit is contained in:
Kamil Kisiela 2022-11-23 15:06:36 +01:00 committed by GitHub
parent e7bbd01212
commit cbaf4c40f3
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
packages/services/usage-ingestor/src/writer.ts
View file

@ -75,7 +75,7 @@ export function createWriter({
await Promise.all([
writeCsv(clickhouse, agents, sql, compressed, logger, 3),
clickhouseMirror
? writeCsv(clickhouseMirror, agents, sql, compressed, logger, 1).catch(error => {
? writeCsv(clickhouseMirror, agents, sql, compressed, logger, 3).catch(error => {
logger.error('Failed to write operations to ClickHouse Cloud %s', error);
// Ignore errors from clickhouse cloud
return Promise.resolve();
@ -95,7 +95,7 @@ export function createWriter({
await Promise.all([
writeCsv(clickhouse, agents, sql, compressed, logger, 3),
clickhouseMirror
? writeCsv(clickhouseMirror, agents, sql, compressed, logger, 1).catch(error => {
? writeCsv(clickhouseMirror, agents, sql, compressed, logger, 3).catch(error => {
logger.error('Failed to write operation_collection to ClickHouse Cloud %s', error);
// Ignore errors from clickhouse cloud
return Promise.resolve();
@ -185,7 +185,7 @@ async function writeCsv(
logger.debug('Retry %s/%s for %s', info.attemptCount, maxRetry, query);
return info.attemptCount * 250;
return info.attemptCount * 500;
},
},
timeout: {