diff --git a/worker.js b/worker.js index 1281f75..42482d7 100644 --- a/worker.js +++ b/worker.js @@ -50,6 +50,7 @@ async function main() { writeState(latestMarketState, paper, strategies); if (!state) return; + if (paper._resetting) return; for (const strategy of strategies) { if (!strategy.enabled) continue; @@ -70,6 +71,11 @@ async function main() { tracker.on('settled', async ({ ticker, result }) => { console.log(`[Worker] Market ${ticker} settled: ${result}`); + if (paper._resetting) { + console.log(`[Worker] Skipping settlement for ${ticker} — reset in progress`); + return; + } + const settledPositions = await paper.settle(ticker, result); for (const strategy of strategies) {