Skip to content

Commit

Permalink
Fix build
Browse files Browse the repository at this point in the history
Signed-off-by: Thomas Farr <tsfarr@amazon.com>
  • Loading branch information
Xtansia committed Feb 10, 2025
1 parent 3686a85 commit ee6e12f
Show file tree
Hide file tree
Showing 32 changed files with 92 additions and 91 deletions.
3 changes: 2 additions & 1 deletion CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,7 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
- Bumps `NSwag.Core` from 14.1.0 to 14.2.0
- Bumps `Argu` from 6.2.4 to 6.2.5
- Bumps `SemanticVersioning` from 2.0.2 to 3.0.0
- Bumps `FSharp.Data` from 6.4.0 to 6.4.1

## [1.8.0]
### Added
Expand Down Expand Up @@ -237,4 +238,4 @@ Inspired from [Keep a Changelog](https://keepachangelog.com/en/1.0.0/)
[1.6.0]: https://github.com/opensearch-project/opensearch-net/compare/v1.5.0...v1.6.0
[1.5.0]: https://github.com/opensearch-project/opensearch-net/compare/v1.4.0...v1.5.0
[1.4.0]: https://github.com/opensearch-project/opensearch-net/compare/v1.3.0...v1.4.0
[1.3.0]: https://github.com/opensearch-project/opensearch-net/compare/v1.2.0...v1.3.0
[1.3.0]: https://github.com/opensearch-project/opensearch-net/compare/v1.2.0...v1.3.0
2 changes: 1 addition & 1 deletion tests/Tests.Reproduce/GithubIssue2323.cs
Original file line number Diff line number Diff line change
Expand Up @@ -71,7 +71,7 @@ public void NestedInnerHitsShouldIncludedNestedProperty()

hitMetadata.Nested.Should().NotBeNull();
hitMetadata.Nested.Field.Should().Be(new Field("tags"));
hitMetadata.Nested.Offset.Should().BeGreaterOrEqualTo(0);
hitMetadata.Nested.Offset.Should().BeGreaterThanOrEqualTo(0);
}
}
}
2 changes: 1 addition & 1 deletion tests/Tests.Reproduce/GithubIssue3715.cs
Original file line number Diff line number Diff line change
Expand Up @@ -667,7 +667,7 @@ private static void AssertExtendedStats(AggregateDictionary bucket, string name)
{
var extendedStatsAggregate = bucket.ExtendedStats(name);
extendedStatsAggregate.Should().NotBeNull();
extendedStatsAggregate.Count.Should().BeGreaterOrEqualTo(0);
extendedStatsAggregate.Count.Should().BeGreaterThanOrEqualTo(0);
extendedStatsAggregate.StdDeviationBounds.Should().NotBeNull();
}

Expand Down
2 changes: 1 addition & 1 deletion tests/Tests.YamlRunner/Tests.YamlRunner.fsproj
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
<PackageReference Update="FSharp.Core" Version="9.0.101" />

<PackageReference Include="Argu" Version="6.2.5" />
<PackageReference Include="FSharp.Data" Version="6.4.0" />
<PackageReference Include="FSharp.Data" Version="6.4.1" />
<PackageReference Include="Newtonsoft.Json" Version="13.0.3" />
<PackageReference Include="SemanticVersioning" Version="3.0.0" />
<PackageReference Include="SharpYaml" Version="2.1.1" />
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -148,7 +148,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
commits.Buckets.Should().NotBeNull();

foreach (var bucket in commits.Buckets)
bucket.Key.Should().BeGreaterOrEqualTo(HardBoundsMinimum).And.BeLessOrEqualTo(HardBoundsMaximum);
bucket.Key.Should().BeGreaterThanOrEqualTo(HardBoundsMinimum).And.BeLessThanOrEqualTo(HardBoundsMaximum);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
foreach (var item in rareTerms.Buckets)
{
item.Key.Should().NotBeNullOrEmpty();
item.DocCount.Should().BeGreaterOrEqualTo(1);
item.DocCount.Should().BeGreaterThanOrEqualTo(1);
}
rareTerms.Meta.Should().NotBeNull().And.HaveCount(1);
rareTerms.Meta["foo"].Should().Be("bar");
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -268,7 +268,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
foreach (var item in commits.Buckets)
{
item.Key.Should().BeGreaterThan(0);
item.DocCount.Should().BeGreaterOrEqualTo(1);
item.DocCount.Should().BeGreaterThanOrEqualTo(1);
}
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
foreach (var item in states.Buckets)
{
item.Key.Should().NotBeNullOrEmpty();
item.DocCount.Should().BeGreaterOrEqualTo(1);
item.DocCount.Should().BeGreaterThanOrEqualTo(1);
}
states.Meta.Should().NotBeNull().And.HaveCount(1);
states.Meta["foo"].Should().Be("bar");
Expand Down Expand Up @@ -225,7 +225,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
foreach (var item in states.Buckets)
{
item.Key.Should().BeDefined();
item.DocCount.Should().BeGreaterOrEqualTo(1);
item.DocCount.Should().BeGreaterThanOrEqualTo(1);
}
states.Meta.Should().NotBeNull().And.HaveCount(1);
states.Meta["foo"].Should().Be("bar");
Expand Down Expand Up @@ -321,7 +321,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
foreach (var item in states.Buckets)
{
item.Key.Should().NotBeNullOrEmpty();
item.DocCount.Should().BeGreaterOrEqualTo(1);
item.DocCount.Should().BeGreaterThanOrEqualTo(1);
}
states.Meta.Should().NotBeNull().And.HaveCount(1);
states.Meta["foo"].Should().Be("bar");
Expand Down Expand Up @@ -383,7 +383,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
foreach (var item in commits.Buckets)
{
item.Key.Should().BeGreaterThan(0);
item.DocCount.Should().BeGreaterOrEqualTo(1);
item.DocCount.Should().BeGreaterThanOrEqualTo(1);
}
}
}
Expand Down Expand Up @@ -438,7 +438,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
foreach (var item in commits.Buckets)
{
item.Key.Should().BeGreaterThan(0);
item.DocCount.Should().BeGreaterOrEqualTo(1);
item.DocCount.Should().BeGreaterThanOrEqualTo(1);
}
commits.Buckets.Should().Contain(b => b.DocCountErrorUpperBound.HasValue);
}
Expand Down Expand Up @@ -504,7 +504,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
foreach (var item in commits.Buckets)
{
item.Key.Should().BeGreaterThan(0);
item.DocCount.Should().BeGreaterOrEqualTo(1);
item.DocCount.Should().BeGreaterThanOrEqualTo(1);
var states = item.Terms("state");
states.Should().NotBeNull();
states.Buckets.Should().NotBeEmpty();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
{
var commits = item.Sum("commits");
commits.Should().NotBeNull();
commits.Value.Should().BeGreaterOrEqualTo(500);
commits.Value.Should().BeGreaterThanOrEqualTo(500);
}
}
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)

var numberOfCommits = value.Value;
if (Math.Abs(previousCommits - (-1)) > double.Epsilon)
numberOfCommits.Should().BeLessOrEqualTo(previousCommits);
numberOfCommits.Should().BeLessThanOrEqualTo(previousCommits);

previousCommits = numberOfCommits;
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
maxCommits.Should().NotBeNull();
maxCommits.Value.Should().BeGreaterThan(0);
maxCommits.Keys.Should().NotBeNull();
maxCommits.Keys.Count.Should().BeGreaterOrEqualTo(1);
maxCommits.Keys.Count.Should().BeGreaterThanOrEqualTo(1);
foreach (var key in maxCommits.Keys)
key.Should().NotBeNull();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -105,7 +105,7 @@ protected override void ExpectResponse(ISearchResponse<Project> response)
minCommits.Should().NotBeNull();
minCommits.Value.Should().BeGreaterThan(0);
minCommits.Keys.Should().NotBeNull();
minCommits.Keys.Count.Should().BeGreaterOrEqualTo(1);
minCommits.Keys.Count.Should().BeGreaterThanOrEqualTo(1);
foreach (var key in minCommits.Keys)
key.Should().NotBeNullOrEmpty();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ private static void AssertHttpStats(IOpenSearchClient c, NodesStatsResponse r, i
{
node.Http.TotalOpened.Should().BeGreaterThan(2, "We want to see some concurrency");
var h = node.Http;
node.Http.CurrentOpen.Should().BeLessOrEqualTo(maxCurrentOpen, $"CurrentOpen exceed our connection limit {maxCurrent}");
node.Http.CurrentOpen.Should().BeLessThanOrEqualTo(maxCurrentOpen, $"CurrentOpen exceed our connection limit {maxCurrent}");

string errorMessage;
int iterationMax;
Expand All @@ -109,7 +109,7 @@ private static void AssertHttpStats(IOpenSearchClient c, NodesStatsResponse r, i
errorMessage =
$"Expected some socket bleeding but iteration {i} exceeded iteration specific max {iterationMax} = (({maxCurrent} * {m}) / 2) + {leeWay}";
}
node.Http.TotalOpened.Should().BeLessOrEqualTo(iterationMax, errorMessage);
node.Http.TotalOpened.Should().BeLessThanOrEqualTo(iterationMax, errorMessage);
if (i == -1) return;

Console.WriteLine(
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ public void RequestWithMultipleWarning()
var response = this.Client.Search<Project>(request);

response.ApiCall.DeprecationWarnings.Should().NotBeNullOrEmpty();
response.ApiCall.DeprecationWarnings.Should().HaveCountGreaterOrEqualTo(2);
response.ApiCall.DeprecationWarnings.Should().HaveCountGreaterThanOrEqualTo(2);
response.DebugInformation.Should().Contain("Deprecated aggregation order key"); // <1> `DebugInformation` also contains the deprecation warnings
}
}
Expand Down
20 changes: 10 additions & 10 deletions tests/Tests/Cluster/ClusterHealth/ClusterHealthApiTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -61,10 +61,10 @@ protected override void ExpectResponse(ClusterHealthResponse response)
response.ClusterName.Should().NotBeNullOrWhiteSpace();
response.Status.Should().NotBe(HealthStatus.Red);
response.TimedOut.Should().BeFalse();
response.NumberOfNodes.Should().BeGreaterOrEqualTo(1);
response.NumberOfDataNodes.Should().BeGreaterOrEqualTo(1);
response.ActivePrimaryShards.Should().BeGreaterOrEqualTo(1);
response.ActiveShards.Should().BeGreaterOrEqualTo(1);
response.NumberOfNodes.Should().BeGreaterThanOrEqualTo(1);
response.NumberOfDataNodes.Should().BeGreaterThanOrEqualTo(1);
response.ActivePrimaryShards.Should().BeGreaterThanOrEqualTo(1);
response.ActiveShards.Should().BeGreaterThanOrEqualTo(1);
}
}

Expand Down Expand Up @@ -93,14 +93,14 @@ protected override void ExpectResponse(ClusterHealthResponse response)
response.ClusterName.Should().NotBeNullOrWhiteSpace();
response.Status.Should().NotBe(HealthStatus.Red);
response.TimedOut.Should().BeFalse();
response.NumberOfNodes.Should().BeGreaterOrEqualTo(1);
response.NumberOfDataNodes.Should().BeGreaterOrEqualTo(1);
response.ActivePrimaryShards.Should().BeGreaterOrEqualTo(1);
response.ActiveShards.Should().BeGreaterOrEqualTo(1);
response.NumberOfNodes.Should().BeGreaterThanOrEqualTo(1);
response.NumberOfDataNodes.Should().BeGreaterThanOrEqualTo(1);
response.ActivePrimaryShards.Should().BeGreaterThanOrEqualTo(1);
response.ActiveShards.Should().BeGreaterThanOrEqualTo(1);
response.ActiveShardsPercentAsNumber.Should().BePositive();
response.DelayedUnassignedShards.Should().Be(0);
response.NumberOfInFlightFetch.Should().BeGreaterOrEqualTo(0);
response.TaskMaxWaitTimeInQueueInMilliseconds.Should().BeGreaterOrEqualTo(0);
response.NumberOfInFlightFetch.Should().BeGreaterThanOrEqualTo(0);
response.TaskMaxWaitTimeInQueueInMilliseconds.Should().BeGreaterThanOrEqualTo(0);

response.Indices.Should()
.NotBeEmpty()
Expand Down
4 changes: 2 additions & 2 deletions tests/Tests/Cluster/ClusterStats/ClusterStatsApiTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -71,9 +71,9 @@ protected void Assert(ClusterNodesStats nodes)
nodes.Should().NotBeNull();
nodes.Count.Should().NotBeNull();
if (Cluster.ClusterConfiguration.Version < "2.0.0")
nodes.Count.Master.Should().BeGreaterOrEqualTo(1);
nodes.Count.Master.Should().BeGreaterThanOrEqualTo(1);
else
nodes.Count.ClusterManager.Should().BeGreaterOrEqualTo(1);
nodes.Count.ClusterManager.Should().BeGreaterThanOrEqualTo(1);

nodes.FileSystem.Should().NotBeNull();
nodes.FileSystem.AvailableInBytes.Should().BeGreaterThan(0);
Expand Down
6 changes: 3 additions & 3 deletions tests/Tests/Cluster/NodesInfo/NodesInfoApiTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -132,8 +132,8 @@ protected void Assert(NodeJvmInfo jvm)
jvm.GcCollectors.Should().NotBeEmpty();
jvm.MemoryPools.Should().NotBeEmpty();
jvm.Memory.Should().NotBeNull();
jvm.Memory.DirectMaxInBytes.Should().BeGreaterOrEqualTo(0);
jvm.Memory.NonHeapMaxInBytes.Should().BeGreaterOrEqualTo(0);
jvm.Memory.DirectMaxInBytes.Should().BeGreaterThanOrEqualTo(0);
jvm.Memory.NonHeapMaxInBytes.Should().BeGreaterThanOrEqualTo(0);
jvm.Memory.NonHeapInitInBytes.Should().BeGreaterThan(0);
jvm.Memory.HeapMaxInBytes.Should().BeGreaterThan(0);
jvm.Memory.HeapInitInBytes.Should().BeGreaterThan(0);
Expand All @@ -145,7 +145,7 @@ protected void Assert(IReadOnlyDictionary<string, NodeThreadPoolInfo> pools)
var pool = pools["fetch_shard_store"];
pool.KeepAlive.Should().NotBeNullOrWhiteSpace();
pool.Type.Should().Be("scaling");
pool.QueueSize.Should().BeGreaterOrEqualTo(-1);
pool.QueueSize.Should().BeGreaterThanOrEqualTo(-1);

// both should have a value for a scaling pool
pool.Core.Should().HaveValue();
Expand Down
30 changes: 15 additions & 15 deletions tests/Tests/Cluster/NodesStats/NodesStatsApiTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -226,7 +226,7 @@ protected void Assert(NodeJvmStats jvm)
jvm.Classes.Should().NotBeNull();
//jvm.Classes.CurrentLoadedCount.Should().BeGreaterThan(0);
//jvm.Classes.TotalLoadedCount.Should().BeGreaterThan(0);
//jvm.Classes.TotalUnloadedCount.Should().BeGreaterOrEqualTo(0);
//jvm.Classes.TotalUnloadedCount.Should().BeGreaterThanOrEqualTo(0);

jvm.GarbageCollection.Should().NotBeNull();
jvm.GarbageCollection.Collectors.Should().NotBeEmpty().And.ContainKey("young");
Expand Down Expand Up @@ -257,33 +257,33 @@ protected void Assert(NodeJvmStats jvm)

protected void Assert(IndexingPressureStats indexingPressureStats)
{
indexingPressureStats.Memory.LimitInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.LimitInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Limit.Should().NotBeNull();

indexingPressureStats.Memory.Current.CombinedCoordinatingAndPrimaryInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Current.CombinedCoordinatingAndPrimaryInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Current.CombinedCoordinatingAndPrimary.Should().NotBeNull();
indexingPressureStats.Memory.Current.CoordinatingInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Current.CoordinatingInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Current.Coordinating.Should().NotBeNull();
indexingPressureStats.Memory.Current.PrimaryInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Current.PrimaryInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Current.Primary.Should().NotBeNull();
indexingPressureStats.Memory.Current.ReplicaInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Current.ReplicaInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Current.Replica.Should().NotBeNull();
indexingPressureStats.Memory.Current.AllInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Current.AllInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Current.All.Should().NotBeNull();

indexingPressureStats.Memory.Total.CombinedCoordinatingAndPrimaryInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Total.CombinedCoordinatingAndPrimaryInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Total.CombinedCoordinatingAndPrimary.Should().NotBeNull();
indexingPressureStats.Memory.Total.CoordinatingInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Total.CoordinatingInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Total.Coordinating.Should().NotBeNull();
indexingPressureStats.Memory.Total.PrimaryInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Total.PrimaryInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Total.Primary.Should().NotBeNull();
indexingPressureStats.Memory.Total.ReplicaInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Total.ReplicaInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Total.Replica.Should().NotBeNull();
indexingPressureStats.Memory.Total.AllInBytes.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Total.AllInBytes.Should().BeGreaterThanOrEqualTo(0);
//indexingPressureStats.Memory.Total.All.Should().NotBeNull();
indexingPressureStats.Memory.Total.CoordinatingRejections.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Total.PrimaryRejections.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Total.ReplicaRejections.Should().BeGreaterOrEqualTo(0);
indexingPressureStats.Memory.Total.CoordinatingRejections.Should().BeGreaterThanOrEqualTo(0);
indexingPressureStats.Memory.Total.PrimaryRejections.Should().BeGreaterThanOrEqualTo(0);
indexingPressureStats.Memory.Total.ReplicaRejections.Should().BeGreaterThanOrEqualTo(0);
}
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -57,8 +57,8 @@ protected override void ExpectResponse(ReloadSecureSettingsResponse response)
{
response.Nodes.Should().NotBeEmpty();
response.NodeStatistics.Should().NotBeNull();
response.NodeStatistics.Total.Should().BeGreaterOrEqualTo(1);
response.NodeStatistics.Successful.Should().BeGreaterOrEqualTo(1);
response.NodeStatistics.Total.Should().BeGreaterThanOrEqualTo(1);
response.NodeStatistics.Successful.Should().BeGreaterThanOrEqualTo(1);
response.ClusterName.Should().NotBeNullOrWhiteSpace();

}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,7 @@ protected override void ExpectResponse(ListTasksResponse response)
taskExecutingNode.Name.Should().NotBeNullOrWhiteSpace();
taskExecutingNode.TransportAddress.Should().NotBeNullOrWhiteSpace();
taskExecutingNode.Tasks.Should().NotBeEmpty();
taskExecutingNode.Tasks.Count().Should().BeGreaterOrEqualTo(2);
taskExecutingNode.Tasks.Count().Should().BeGreaterThanOrEqualTo(2);

var task = taskExecutingNode.Tasks.Values.First(p => p.ParentTaskId != null);
task.Action.Should().NotBeNullOrWhiteSpace();
Expand Down Expand Up @@ -163,7 +163,7 @@ protected override void ExpectResponse(ListTasksResponse response)
taskExecutingNode.Name.Should().NotBeNullOrWhiteSpace();
taskExecutingNode.TransportAddress.Should().NotBeNullOrWhiteSpace();
taskExecutingNode.Tasks.Should().NotBeEmpty();
taskExecutingNode.Tasks.Count().Should().BeGreaterOrEqualTo(1);
taskExecutingNode.Tasks.Count.Should().BeGreaterThanOrEqualTo(1);

var task = taskExecutingNode.Tasks[_taskId];
task.Action.Should().NotBeNullOrWhiteSpace();
Expand All @@ -175,8 +175,8 @@ protected override void ExpectResponse(ListTasksResponse response)

var status = task.Status;
status.Should().NotBeNull();
status.Total.Should().BeGreaterOrEqualTo(0);
status.Batches.Should().BeGreaterOrEqualTo(0);
status.Total.Should().BeGreaterThanOrEqualTo(0);
status.Batches.Should().BeGreaterThanOrEqualTo(0);
}
}
}
2 changes: 1 addition & 1 deletion tests/Tests/Document/Multiple/Bulk/BulkApiTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -179,7 +179,7 @@ protected override void ExpectResponse(BulkResponse response)
item.Shards.Should().NotBeNull();
item.Shards.Total.Should().BeGreaterThan(0);
item.Shards.Successful.Should().BeGreaterThan(0);
item.SequenceNumber.Should().BeGreaterOrEqualTo(0);
item.SequenceNumber.Should().BeGreaterThanOrEqualTo(0);
item.PrimaryTerm.Should().BeGreaterThan(0);
item.Result.Should().NotBeNullOrEmpty();
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -76,7 +76,7 @@ [I] public async Task SubscribeHitsOnError()
b =>
{
Interlocked.Increment(ref seenPages);
b.Page.Should().BeLessOrEqualTo(FailAfterPage - 1);
b.Page.Should().BeLessThanOrEqualTo(FailAfterPage - 1);
},
e =>
{
Expand Down
4 changes: 2 additions & 2 deletions tests/Tests/Document/Multiple/MultiGet/MultiGetApiTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -199,8 +199,8 @@ protected override void ExpectResponse(MultiGetResponse response)
hit.Id.Should().NotBeNullOrWhiteSpace();
hit.Found.Should().BeTrue();
hit.Version.Should().Be(1);
hit.PrimaryTerm.Should().BeGreaterOrEqualTo(1);
hit.SequenceNumber.Should().BeGreaterOrEqualTo(0);
hit.PrimaryTerm.Should().BeGreaterThanOrEqualTo(1);
hit.SequenceNumber.Should().BeGreaterThanOrEqualTo(0);
hit.Source.ShouldAdhereToSourceSerializerWhenSet();
}
}
Expand Down
2 changes: 1 addition & 1 deletion tests/Tests/Document/Single/Create/CreateApiTests.cs
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ public void CreateWithSameIndexTypeAndId()
createResponse.Shards.Total.Should().BeGreaterThan(0);
createResponse.Shards.Successful.Should().BeGreaterThan(0);
createResponse.PrimaryTerm.Should().BeGreaterThan(0);
createResponse.SequenceNumber.Should().BeGreaterOrEqualTo(0);
createResponse.SequenceNumber.Should().BeGreaterThanOrEqualTo(0);

createResponse = Client.Create(project, f => f
.Index(index)
Expand Down
Loading

0 comments on commit ee6e12f

Please sign in to comment.