Make it possible to shutdown unfinished scaffolder ongoing tasks after restart
Signed-off-by: Bogdan Nechyporenko <bnechyporenko@bol.com>
This commit is contained in:
@@ -301,7 +301,7 @@ export async function createRouter(
|
||||
|
||||
const actionRegistry = new TemplateActionRegistry();
|
||||
|
||||
const workers: TaskWorker[] = [];
|
||||
const workers = [];
|
||||
if (concurrentTasksLimit !== 0) {
|
||||
for (let i = 0; i < (taskWorkers || 1); i++) {
|
||||
const worker = await TaskWorker.create({
|
||||
@@ -516,10 +516,6 @@ export async function createRouter(
|
||||
delete task.secrets;
|
||||
res.status(200).json(task);
|
||||
})
|
||||
.post('/v2/tasks/cancel', async (req, res) => {
|
||||
workers.forEach(worker => worker.cancelAllRunningTasks());
|
||||
res.status(200).json({ status: 'cancelled' });
|
||||
})
|
||||
.post('/v2/tasks/:taskId/cancel', async (req, res) => {
|
||||
const { taskId } = req.params;
|
||||
await taskBroker.cancel?.(taskId);
|
||||
|
||||
Reference in New Issue
Block a user