From 19b025ef2f5cbda68e386b323950ab78aefde09d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Miroslav=20Bajto=C5=A1?= Date: Wed, 13 Dec 2023 10:25:35 +0100 Subject: [PATCH] fixup! fix typos + add log MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Miroslav Bajtoš --- lib/spark.js | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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) } }