ExternalVendorCode/onefuzz
1
0
Fork 0
mirror of https://github.com/microsoft/onefuzz.git synced 2025-06-22 22:28:50 +00:00
Code Issues Packages Projects Releases Wiki Activity

include state filter when searching for expired jobs and tasks (#2138)

Browse Source
This commit is contained in:
Cheick Keita
2022-07-07 14:53:51 -07:00
committed by GitHub
parent edf537137b
commit ff1d088fa1
2 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/ApiService/ApiService/onefuzzlib/JobOperations.cs
View File

@ -29,7 +29,10 @@ public class JobOperations : StatefulOrm<Job, JobState, JobOperations>, IJobOper
} }
public IAsyncEnumerable<Job> SearchExpired() { public IAsyncEnumerable<Job> SearchExpired() {
return QueryAsync(filter: $"end_time lt datetime'{DateTimeOffset.UtcNow.ToString("o")}'"); var timeFilter = $"end_time lt datetime'{DateTimeOffset.UtcNow.ToString("o")}'";
var stateFilter = Query.EqualAnyEnum("state", JobStateHelper.Available);
var filter = Query.And(stateFilter, timeFilter);
return QueryAsync(filter: filter);
} }
public IAsyncEnumerable<Job> SearchState(IEnumerable<JobState> states) { public IAsyncEnumerable<Job> SearchState(IEnumerable<JobState> states) {

6
src/ApiService/ApiService/onefuzzlib/TaskOperations.cs
View File

@ -68,8 +68,10 @@ public class TaskOperations : StatefulOrm<Task, TaskState, TaskOperations>, ITas
} }
public IAsyncEnumerable<Task> SearchExpired() { public IAsyncEnumerable<Task> SearchExpired() {
var timeFilter = $"end_time lt Datetime'{DateTimeOffset.UtcNow.ToString("o")}'"; var timeFilter = $"end_time lt datetime'{DateTimeOffset.UtcNow.ToString("o")}'";
return QueryAsync(filter: timeFilter); var stateFilter = Query.EqualAnyEnum("state", TaskStateHelper.AvailableStates);
var filter = Query.And(stateFilter, timeFilter);
return QueryAsync(filter: filter);
} }
public async Async.Task MarkStopping(Task task) { public async Async.Task MarkStopping(Task task) {