Skip to content

Commit

Permalink
Improve test assertion
Browse files Browse the repository at this point in the history
  • Loading branch information
thomhurst committed Aug 28, 2024
1 parent 9670b04 commit 8ddce91
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 8 deletions.
14 changes: 7 additions & 7 deletions test/ModularPipelines.UnitTests/NotInParallelTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

namespace ModularPipelines.UnitTests;

[Retry(3)]
public class NotInParallelTests
{
[ModularPipelines.Attributes.NotInParallel]
Expand Down Expand Up @@ -58,7 +59,7 @@ public class NotParallelModuleWithNonParallelDependency : Module<string>
}
}

[Test, Retry(3)]
[Test]
public async Task NotInParallel()
{
var results = await TestPipelineHostBuilder.Create()
Expand All @@ -69,11 +70,10 @@ public async Task NotInParallel()
var firstModule = results.Modules.MinBy(x => x.EndTime)!;
var nextModule = results.Modules.MaxBy(x => x.EndTime)!;
await Assert.That(nextModule.StartTime)
.Is.EqualToWithTolerance(firstModule.StartTime + TimeSpan.FromSeconds(5),
TimeSpan.FromSeconds(1));
.Is.GreaterThanOrEqualTo(firstModule.StartTime + TimeSpan.FromSeconds(5));
}

[Test, Retry(3)]
[Test]
public async Task NotInParallel_With_ParallelDependency()
{
var results = await TestPipelineHostBuilder.Create()
Expand All @@ -84,10 +84,10 @@ public async Task NotInParallel_With_ParallelDependency()
var firstModule = results.Modules.MinBy(x => x.EndTime)!;
var nextModule = results.Modules.MaxBy(x => x.EndTime)!;
await Assert.That(nextModule.StartTime)
.Is.EqualToWithTolerance(firstModule.StartTime + TimeSpan.FromSeconds(5), TimeSpan.FromSeconds(1));
.Is.GreaterThanOrEqualTo(firstModule.StartTime + TimeSpan.FromSeconds(5));
}

[Test, Retry(3)]
[Test]
public async Task NotInParallel_With_NonParallelDependency()
{
var results = await TestPipelineHostBuilder.Create()
Expand All @@ -102,6 +102,6 @@ public async Task NotInParallel_With_NonParallelDependency()
var expectedStartTime = firstModule.StartTime + TimeSpan.FromSeconds(10);

await Assert.That(nextModule.StartTime)
.Is.EqualToWithTolerance(expectedStartTime, TimeSpan.FromSeconds(1));
.Is.GreaterThanOrEqualTo(expectedStartTime);
}
}
3 changes: 2 additions & 1 deletion test/ModularPipelines.UnitTests/ParallelLimiterTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@

namespace ModularPipelines.UnitTests;

[Retry(3)]
public class ParallelLimiterTests
{
[ModularPipelines.Attributes.ParallelLimiter<MyParallelLimit>]
Expand Down Expand Up @@ -68,7 +69,7 @@ public class Module6 : Module<string>
}
}

[Test, Repeat(3)]
[Test]
public async Task LimitParallel()
{
var results = await TestPipelineHostBuilder.Create()
Expand Down

0 comments on commit 8ddce91

Please sign in to comment.