Made shut down stale tasks configurable.

Signed-off-by: Bogdan Nechyporenko <bnechyporenko@bol.com>
2023-10-14 23:14:36 +02:00
parent de7513e7fa
commit ca3f355851
1 changed files with 4 additions and 4 deletions
@@ -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.`,
            );
          }
        });