From ca3f355851ed59c6742cb48297d8f1d1951d3fee Mon Sep 17 00:00:00 2001 From: Bogdan Nechyporenko Date: Sat, 14 Oct 2023 23:14:36 +0200 Subject: [PATCH] Made shut down stale tasks configurable. Signed-off-by: Bogdan Nechyporenko --- plugins/scaffolder-backend/src/ScaffolderPlugin.ts | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/plugins/scaffolder-backend/src/ScaffolderPlugin.ts b/plugins/scaffolder-backend/src/ScaffolderPlugin.ts index b9d5d69791..b3fb850907 100644 --- a/plugins/scaffolder-backend/src/ScaffolderPlugin.ts +++ b/plugins/scaffolder-backend/src/ScaffolderPlugin.ts @@ -110,18 +110,18 @@ export const scaffolderPlugin = createBackendPlugin({ const databaseTaskStore = await DatabaseTaskStore.create({ database, }); - const { tasks: pendingTasks } = await databaseTaskStore.list({ + const { tasks: processingTasks } = await databaseTaskStore.list({ status: 'processing', }); - if (pendingTasks.length > 0) { + if (processingTasks.length > 0) { await Promise.all( - pendingTasks.map(task => + processingTasks.map(task => databaseTaskStore.shutdownTask({ taskId: task.id }), ), ); logger.info( - `Successfully shut ${pendingTasks.length} processing tasks down.`, + `Successfully shut ${processingTasks.length} processing tasks down.`, ); } });