Skip to content

Commit 7575af4

Browse files
committed
minor fix to query
Signed-off-by: Lillie Dae <[email protected]>
1 parent 2674f64 commit 7575af4

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/WorkflowManager/Database/Repositories/TaskExecutionStatsRepository.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -229,8 +229,8 @@ public async Task<long> GetStatsCountAsync(DateTime startTime, DateTime endTime,
229229
var builder = Builders<ExecutionStats>.Filter;
230230
var filter = builder.Empty;
231231

232-
filter &= builder.Where(t => t.StartedUTC == startTime.ToUniversalTime());
233-
filter &= builder.Where(t => t.StartedUTC == endTime.ToUniversalTime());
232+
filter &= builder.Where(t => t.StartedUTC >= startTime.ToUniversalTime());
233+
filter &= builder.Where(t => t.StartedUTC <= endTime.ToUniversalTime());
234234
filter &= builder.Where(t => workflowNull || t.WorkflowId == workflowId);
235235
filter &= builder.Where(t => taskIdNull || t.TaskId == taskId);
236236
if (statusFilter is not null)

0 commit comments

Comments
 (0)