Fix tests

aneoconsulting · Aug 6, 2024 · ab98a30 · ab98a30
1 parent 6d3d088
commit ab98a30
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/Common/src/Pollster/RunningTaskProcessor.cs b/Common/src/Pollster/RunningTaskProcessor.cs
@@ -59,7 +59,7 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
         TaskHandler taskHandler;
         try
         {
-          taskHandler = await runningTaskQueue_.ReadAsync(exceptionManager_.EarlyCancellationToken)
+          taskHandler = await runningTaskQueue_.ReadAsync(exceptionManager_.LateCancellationToken)
                                                .ConfigureAwait(false);
         }
         catch (OperationCanceledException)

diff --git a/Common/tests/Pollster/TaskHandlerTest.cs b/Common/tests/Pollster/TaskHandlerTest.cs
@@ -1606,7 +1606,7 @@ await testServiceProvider.TaskHandler.StopCancelledTask()
                     await testServiceProvider.TaskTable.GetTaskStatus(taskId)
                                              .ConfigureAwait(false));
 
-    Assert.AreEqual(QueueMessageStatus.Processed,
+    Assert.AreEqual(QueueMessageStatus.Cancelled,
                     sqmh.Status);
   }
 }