Skip to content

Flow CancellationToken through durable jobs tests #9909

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
ReubenBond merged 2 commits into from
Feb 16, 2026
Merged

Flow CancellationToken through durable jobs tests #9909

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
9f106b5
Flow CancellationToken through durable jobs tests with 2-minute timeout
Copilot Feb 12, 2026
436f30f
Use .WaitAsync(cancellationToken) in DurableJobTestsRunner to observe…
Copilot Feb 12, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
93 changes: 67 additions & 26 deletions test/DefaultCluster.Tests/InMemoryDurableJobsTests.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,3 +1,5 @@
using System;
using System.Threading;
using System.Threading.Tasks;
using Tester.DurableJobs;
using TestExtensions;
Expand All @@ -15,54 +17,93 @@ public InMemoryDurableJobsTests(DefaultClusterFixture fixture) : base(fixture)
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task DurableJobGrain()
=> _runner.DurableJobGrain();
public async Task DurableJobGrain()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.DurableJobGrain(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task JobExecutionOrder()
=> _runner.JobExecutionOrder();
public async Task JobExecutionOrder()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.JobExecutionOrder(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task PastDueTime()
=> _runner.PastDueTime();
public async Task PastDueTime()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.PastDueTime(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task JobWithMetadata()
=> _runner.JobWithMetadata();
public async Task JobWithMetadata()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.JobWithMetadata(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task MultipleGrains()
=> _runner.MultipleGrains();
public async Task MultipleGrains()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.MultipleGrains(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task DuplicateJobNames()
=> _runner.DuplicateJobNames();
public async Task DuplicateJobNames()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.DuplicateJobNames(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task CancelNonExistentJob()
=> _runner.CancelNonExistentJob();
public async Task CancelNonExistentJob()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.CancelNonExistentJob(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task CancelAlreadyExecutedJob()
=> _runner.CancelAlreadyExecutedJob();
public async Task CancelAlreadyExecutedJob()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.CancelAlreadyExecutedJob(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task ConcurrentScheduling()
=> _runner.ConcurrentScheduling();
public async Task ConcurrentScheduling()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.ConcurrentScheduling(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task JobPropertiesVerification()
=> _runner.JobPropertiesVerification();
public async Task JobPropertiesVerification()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.JobPropertiesVerification(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task DequeueCount()
=> _runner.DequeueCount();
public async Task DequeueCount()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.DequeueCount(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task ScheduleJobOnAnotherGrain()
=> _runner.ScheduleJobOnAnotherGrain();
public async Task ScheduleJobOnAnotherGrain()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.ScheduleJobOnAnotherGrain(cts.Token);
}

[Fact, TestCategory("BVT"), TestCategory("DurableJobs")]
public Task JobRetry()
=> _runner.JobRetry();
public async Task JobRetry()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.JobRetry(cts.Token);
}
}
92 changes: 66 additions & 26 deletions test/Extensions/TesterAzureUtils/DurableJobs/AzureStorageBlobDurableJobsTests.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
using System;
using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.DependencyInjection;
using Orleans.Configuration;
Expand Down Expand Up @@ -38,54 +39,93 @@ public void Configure(ISiloBuilder hostBuilder)
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task DurableJobGrain()
=> _runner.DurableJobGrain();
public async Task DurableJobGrain()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.DurableJobGrain(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task JobExecutionOrder()
=> _runner.JobExecutionOrder();
public async Task JobExecutionOrder()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.JobExecutionOrder(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task PastDueTime()
=> _runner.PastDueTime();
public async Task PastDueTime()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.PastDueTime(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task JobWithMetadata()
=> _runner.JobWithMetadata();
public async Task JobWithMetadata()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.JobWithMetadata(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task MultipleGrains()
=> _runner.MultipleGrains();
public async Task MultipleGrains()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.MultipleGrains(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task DuplicateJobNames()
=> _runner.DuplicateJobNames();
public async Task DuplicateJobNames()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.DuplicateJobNames(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task CancelNonExistentJob()
=> _runner.CancelNonExistentJob();
public async Task CancelNonExistentJob()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.CancelNonExistentJob(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task CancelAlreadyExecutedJob()
=> _runner.CancelAlreadyExecutedJob();
public async Task CancelAlreadyExecutedJob()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.CancelAlreadyExecutedJob(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task ConcurrentScheduling()
=> _runner.ConcurrentScheduling();
public async Task ConcurrentScheduling()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.ConcurrentScheduling(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task JobPropertiesVerification()
=> _runner.JobPropertiesVerification();
public async Task JobPropertiesVerification()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.JobPropertiesVerification(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task DequeueCount()
=> _runner.DequeueCount();
public async Task DequeueCount()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.DequeueCount(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task ScheduleJobOnAnotherGrain()
=> _runner.ScheduleJobOnAnotherGrain();
public async Task ScheduleJobOnAnotherGrain()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.ScheduleJobOnAnotherGrain(cts.Token);
}

[SkippableFact, TestCategory("Azure"), TestCategory("DurableJobs")]
public Task JobRetry()
=> _runner.JobRetry();
public async Task JobRetry()
{
using var cts = new CancellationTokenSource(TimeSpan.FromMinutes(2));
await _runner.JobRetry(cts.Token);
}
}
Loading
Loading