dirtydishes/islandflow
1
0
Fork 0
Code Issues 2 Pull requests 4 Projects Releases Packages Wiki Activity Actions 1

Merge pull request #15 from dirtydishes/lavender/prepare-docker-deployment

Browse source 
fix clickhouse startup resilience across services
This commit is contained in:
dirtydishes 2026-04-04 08:37:03 -04:00 • committed by GitHub
commit f425a9575b
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
6 changed files with 9 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

4
deployment/docker/clickhouse/listen.xml
View file

@ -1,3 +1,3 @@
<clickhouse> <yandex>
<listen_host>0.0.0.0</listen_host> <listen_host>0.0.0.0</listen_host>
</clickhouse> </yandex>

2
services/api/src/index.ts
View file

@ -525,7 +525,7 @@ const run = async () => {
database: env.CLICKHOUSE_DATABASE database: env.CLICKHOUSE_DATABASE
}); });
await retry("clickhouse table init", 20, 500, async () => { await retry("clickhouse table init", 120, 500, async () => {
await ensureOptionPrintsTable(clickhouse); await ensureOptionPrintsTable(clickhouse);
await ensureOptionNBBOTable(clickhouse); await ensureOptionNBBOTable(clickhouse);
await ensureEquityPrintsTable(clickhouse); await ensureEquityPrintsTable(clickhouse);

4
services/candles/src/index.ts
View file

@ -271,7 +271,7 @@ const run = async () => {
database: env.CLICKHOUSE_DATABASE database: env.CLICKHOUSE_DATABASE
}); });
await retry("clickhouse table init", 20, 500, async () => { await retry("clickhouse table init", 120, 500, async () => {
await ensureEquityCandlesTable(clickhouse); await ensureEquityCandlesTable(clickhouse);
}); });
@ -287,7 +287,7 @@ const run = async () => {
error: getErrorMessage(error) error: getErrorMessage(error)
}); });
}); });
await retry("redis connect", 20, 500, async () => { await retry("redis connect", 120, 500, async () => {
if (!redis) { if (!redis) {
return; return;
} }

4
services/compute/src/index.ts
View file

@ -1138,7 +1138,7 @@ const run = async () => {
logger.warn("redis client error", { error: error instanceof Error ? error.message : String(error) }); logger.warn("redis client error", { error: error instanceof Error ? error.message : String(error) });
}); });
await retry("redis connect", 20, 500, async () => { await retry("redis connect", 120, 500, async () => {
await redis.connect(); await redis.connect();
}); });
@ -1147,7 +1147,7 @@ const run = async () => {
ttlSeconds: env.ROLLING_TTL_SEC ttlSeconds: env.ROLLING_TTL_SEC
}; };
await retry("clickhouse table init", 20, 500, async () => { await retry("clickhouse table init", 120, 500, async () => {
await ensureFlowPacketsTable(clickhouse); await ensureFlowPacketsTable(clickhouse);
await ensureEquityPrintJoinsTable(clickhouse); await ensureEquityPrintJoinsTable(clickhouse);
await ensureInferredDarkTable(clickhouse); await ensureInferredDarkTable(clickhouse);

2
services/ingest-equities/src/index.ts
View file

@ -212,7 +212,7 @@ const run = async () => {
database: env.CLICKHOUSE_DATABASE database: env.CLICKHOUSE_DATABASE
}); });
await retry("clickhouse table init", 20, 500, async () => { await retry("clickhouse table init", 120, 500, async () => {
await ensureEquityPrintsTable(clickhouse); await ensureEquityPrintsTable(clickhouse);
await ensureEquityQuotesTable(clickhouse); await ensureEquityQuotesTable(clickhouse);
}); });

2
services/ingest-options/src/index.ts
View file

@ -282,7 +282,7 @@ const run = async () => {
database: env.CLICKHOUSE_DATABASE database: env.CLICKHOUSE_DATABASE
}); });
await retry("clickhouse table init", 20, 500, async () => { await retry("clickhouse table init", 120, 500, async () => {
await ensureOptionPrintsTable(clickhouse); await ensureOptionPrintsTable(clickhouse);
await ensureOptionNBBOTable(clickhouse); await ensureOptionNBBOTable(clickhouse);
}); });