diff --git a/lib/spark.js b/lib/spark.js index 2ffb8b9..85fafc2 100644 --- a/lib/spark.js +++ b/lib/spark.js @@ -24,11 +24,11 @@ export default class Spark { }) await assertOkResponse(res, 'Failed to fetch the current SPARK round') this.#activity.onHealthy() - const { retrievalTasks, maxTaskPerNode, ...round } = await res.json() + const { retrievalTasks, maxTasksPerNode, ...round } = await res.json() console.log('Current SPARK round:', round) - console.log(' %s max tasks per node', maxTaskPerNode ?? '') + console.log(' %s max tasks per node', maxTasksPerNode ?? '') console.log(' %s retrieval tasks', retrievalTasks.length) - if (maxTaskPerNode) this.#maxTasksPerNode = maxTaskPerNode + if (maxTasksPerNode) this.#maxTasksPerNode = maxTasksPerNode const retrieval = retrievalTasks[Math.floor(Math.random() * retrievalTasks.length)] console.log({ retrieval }) @@ -180,6 +180,7 @@ export default class Spark { const baseDelay = APPROX_ROUND_LENGTH_IN_MS / this.#maxTasksPerNode const delay = baseDelay - duration if (delay > 0) { + console.log('Sleeping for %s seconds before starting the next task...', Math.round(delay/1000)) await sleep(delay) } }