diff --git a/durablefunctionsmonitor.dotnetbackend/Common/OrchestrationHistory.cs b/durablefunctionsmonitor.dotnetbackend/Common/OrchestrationHistory.cs index 2a80463..97dab48 100644 --- a/durablefunctionsmonitor.dotnetbackend/Common/OrchestrationHistory.cs +++ b/durablefunctionsmonitor.dotnetbackend/Common/OrchestrationHistory.cs @@ -32,7 +32,7 @@ public static IEnumerable GetHistoryDirectlyFromTable(IDurableClie ( instanceIdFilter, TableOperators.And, - TableQuery.GenerateFilterCondition("TaskScheduledId", QueryComparisons.NotEqual, null) + TableQuery.GenerateFilterConditionForInt("TaskScheduledId", QueryComparisons.GreaterThanOrEqual, 0) ) ); @@ -41,15 +41,7 @@ public static IEnumerable GetHistoryDirectlyFromTable(IDurableClie .ContinueWith(t => t.Result.ToDictionary(e => e.TaskScheduledId)); // Fetching the history - var query = new TableQuery().Where - ( - TableQuery.CombineFilters - ( - instanceIdFilter, - TableOperators.And, - TableQuery.GenerateFilterCondition("EventType", QueryComparisons.NotEqual, null) - ) - ); + var query = new TableQuery().Where(instanceIdFilter); // Memorizing 'ExecutionStarted' event, to further correlate with 'ExecutionCompleted' HistoryEntity executionStartedEvent = null;