Skip to content

Commit 0431e2d

Browse files
add api to clear creation queue
1 parent 7df1032 commit 0431e2d

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

ApiController.cs

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -140,6 +140,20 @@ public async Task<IResult> KillNonProcessingRunners()
140140
});
141141
}
142142

143+
[Route("clear-creation-queue")]
144+
[HttpPost]
145+
public async Task<IResult> ClearCreationQueue()
146+
{
147+
await using var db = new ActionsRunnerContext();
148+
var queuedTasks = await db.CreateTaskQueues.ToListAsync();
149+
int count = queuedTasks.Count;
150+
db.CreateTaskQueues.RemoveRange(queuedTasks);
151+
await db.SaveChangesAsync();
152+
153+
_logger.LogWarning($"Creation queue cleared: removed {count} tasks");
154+
return Results.Json(new { message = $"Cleared {count} tasks from creation queue" });
155+
}
156+
143157
[Route("health")]
144158
[HttpGet]
145159
public IResult Health()

0 commit comments

Comments
 (0)