GlcoinCore/mempool
1
0
Fork 0
mirror of https://github.com/mempool/mempool.git synced 2026-08-13 12:33:11 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Merge pull request #6669 from mempool/mononaut/fix-single-task-schedule
Some checks failed
Backend Integration Tests with MariaDB / Backend Integration Tests - node 24.13.0 (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / Backend (dev) - node 24.13.0 (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / Backend (prod) - node 24.13.0 (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / Cache assets for builds (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / Validate generated backend Docker JSON (push) Has been cancelled
Details
Supply Chain Audit / Backend install-script audit (push) Has been cancelled
Details
Supply Chain Audit / Frontend install-script audit (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / Frontend (dev) - node 24.13.0 (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / Frontend (prod) - node 24.13.0 (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / E2E tests for liquid (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / E2E tests for mempool (push) Has been cancelled
Details
CI Pipeline for the Backend and Frontend / E2E tests for testnet4 (push) Has been cancelled
Details

Browse source 
fix scheduleSingleTask
This commit is contained in:
nymkappa 2026-08-02 10:46:02 +02:00 • committed by GitHub
commit 579b46ef84
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
backend/src/indexer.ts
View file

@ -113,12 +113,11 @@ class Indexer {
}
}
this.tasksScheduled[task] = setTimeout(async () => {
delete this.tasksScheduled[task];
try {
await this.runSingleTask(task);
} catch (e) {
logger.err(`Unexpected error in scheduled task ${task}: ` + (e instanceof Error ? e.message : e));
} finally {
clearTimeout(this.tasksScheduled[task]);
}
}, timeout);
}
@ -144,7 +143,8 @@ class Indexer {
latestPriceId = await PricesRepository.$getLatestPriceId();
} catch (e) {
logger.debug('failed to fetch latest price id from db: ' + (e instanceof Error ? e.message : e));
} if (priceUpdater.historyInserted === false || latestPriceId === null) {
}
if (priceUpdater.historyInserted === false || latestPriceId === null) {
logger.debug(`Blocks prices indexer is waiting for the price updater to complete`, logger.tags.mining);
this.scheduleSingleTask(task, 10000);
} else {