chore: Update API to 3.19.0 (#715)

aneoconsulting · Jul 22, 2024 · 2832c98 · 2832c98
2 parents 0dbda4f + 0d97d7c
commit 2832c98
Show file tree

Hide file tree

Showing 17 changed files with 35 additions and 10 deletions.
diff --git a/Common/src/ArmoniK.Core.Common.csproj b/Common/src/ArmoniK.Core.Common.csproj
@@ -26,7 +26,7 @@
 
 
   <ItemGroup>
-    <PackageReference Include="ArmoniK.Api.Core" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Core" Version="3.19.0" />
     <PackageReference Include="ArmoniK.Utils.Diagnostics" Version="0.5.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/Common/src/gRPC/Convertors/TaskDataHolderExt.cs b/Common/src/gRPC/Convertors/TaskDataHolderExt.cs
@@ -37,6 +37,7 @@ public static TaskDetailed ToTaskDetailed(this TaskDataHolder taskData)
     => new()
        {
          SessionId = taskData.SessionId,
+         PayloadId = taskData.PayloadId,
          Status    = taskData.Status.ToGrpcStatus(),
          Output = taskData.Output is not null
                     ? new TaskDetailed.Types.Output
@@ -117,6 +118,7 @@ public static TaskSummary ToTaskSummary(this TaskDataHolder taskDataSummary)
     => new()
        {
          SessionId  = taskDataSummary.SessionId,
+         PayloadId  = taskDataSummary.PayloadId,
          Status     = taskDataSummary.Status.ToGrpcStatus(),
          OwnerPodId = taskDataSummary.OwnerPodId,
          Options    = taskDataSummary.Options?.ToGrpcTaskOptions(),

diff --git a/Common/src/gRPC/EnumFieldExt.cs b/Common/src/gRPC/EnumFieldExt.cs
@@ -58,6 +58,7 @@ public static class EnumFieldExt
        {
          TaskSummaryEnumField.TaskId                  => data => data.TaskId,
          TaskSummaryEnumField.SessionId               => data => data.SessionId,
+         TaskSummaryEnumField.PayloadId               => data => data.PayloadId,
          TaskSummaryEnumField.OwnerPodId              => data => data.OwnerPodId,
          TaskSummaryEnumField.InitialTaskId           => data => data.InitialTaskId,
          TaskSummaryEnumField.Status                  => data => data.Status,

diff --git a/Common/src/gRPC/Services/GrpcTasksService.cs b/Common/src/gRPC/Services/GrpcTasksService.cs
@@ -106,6 +106,7 @@ public GrpcTasksService(ITaskTable                                 taskTable,
                                         {
                                           TaskDataFields.SessionId,
                                           TaskDataFields.TaskId,
+                                          TaskDataFields.PayloadId,
                                           TaskDataFields.Status,
                                           TaskDataFields.InitialTaskId,
                                           TaskDataFields.Output,
@@ -481,7 +482,8 @@ await TaskLifeCycleHelper.FinalizeTaskCreation(taskTable_,
                                                               {
                                                                 creationRequest.ExpectedOutputKeys,
                                                               },
-                                                              TaskId = creationRequest.TaskId,
+                                                              TaskId    = creationRequest.TaskId,
+                                                              PayloadId = creationRequest.PayloadId,
                                                             }),
                },
              };

diff --git a/Common/src/gRPC/Validators/EventSubscriptionRequestValidator.cs b/Common/src/gRPC/Validators/EventSubscriptionRequestValidator.cs
@@ -93,6 +93,7 @@ public override ValidationResult Validate(ValidationContext<EventSubscriptionReq
               {
                 case TaskSummaryEnumField.TaskId:
                 case TaskSummaryEnumField.SessionId:
+                case TaskSummaryEnumField.PayloadId:
                 case TaskSummaryEnumField.OwnerPodId:
                 case TaskSummaryEnumField.InitialTaskId:
                 case TaskSummaryEnumField.PodHostname:

diff --git a/Common/tests/ListTasksRequestExt/ToTaskDataFieldTest.cs b/Common/tests/ListTasksRequestExt/ToTaskDataFieldTest.cs
@@ -94,6 +94,8 @@ TestCaseData CaseSummary(TaskSummaryEnumField field,
                              TaskData.TaskId);
     yield return CaseSummary(TaskSummaryEnumField.SessionId,
                              TaskData.SessionId);
+    yield return CaseSummary(TaskSummaryEnumField.PayloadId,
+                             TaskData.PayloadId);
     yield return CaseSummary(TaskSummaryEnumField.Status,
                              TaskData.Status);
     yield return CaseSummary(TaskSummaryEnumField.CreatedAt,

diff --git a/Common/tests/ListTasksRequestExt/ToTaskDataFilterTest.cs b/Common/tests/ListTasksRequestExt/ToTaskDataFilterTest.cs
@@ -208,6 +208,13 @@ TestCaseData CaseFalse(FilterField filterField)
                                                                        FilterStringOperator.Equal,
                                                                        "BadPartitionId"));
 
+    yield return CaseTrue(ListTasksHelper.CreateListTasksFilterString(TaskSummaryEnumField.PayloadId,
+                                                                      FilterStringOperator.Equal,
+                                                                      "PayloadId"));
+    yield return CaseFalse(ListTasksHelper.CreateListTasksFilterString(TaskSummaryEnumField.PayloadId,
+                                                                       FilterStringOperator.Equal,
+                                                                       "BadPayloadId"));
+
     yield return CaseTrue(ListTasksHelper.CreateListTasksFilterStatus(TaskSummaryEnumField.Status,
                                                                       FilterStatusOperator.Equal,
                                                                       Api.gRPC.V1.TaskStatus.Completed));

diff --git a/Common/tests/TestBase/TaskTableTestBase.cs b/Common/tests/TestBase/TaskTableTestBase.cs
@@ -1892,6 +1892,13 @@ TestCaseData CaseFalse(Api.gRPC.V1.Tasks.FilterField filterField)
                                                                        FilterStringOperator.Equal,
                                                                        "BadSessionId"));
 
+    yield return CaseTrue(ListTasksHelper.CreateListTasksFilterString(TaskSummaryEnumField.PayloadId,
+                                                                      FilterStringOperator.Equal,
+                                                                      "PayloadId"));
+    yield return CaseFalse(ListTasksHelper.CreateListTasksFilterString(TaskSummaryEnumField.PayloadId,
+                                                                       FilterStringOperator.Equal,
+                                                                       "BadPayloadId"));
+
     yield return CaseTrue(ListTasksHelper.CreateListTasksFilterString("key1",
                                                                       FilterStringOperator.Equal,
                                                                       "val1"));

diff --git a/Common/tests/Validators/EventSubscriptionRequestValidatorTest.cs b/Common/tests/Validators/EventSubscriptionRequestValidatorTest.cs
@@ -119,6 +119,9 @@ TestCaseData CaseFalse(FilterField filterField)
     yield return CaseTrue(ListTasksHelper.CreateListTasksFilterString(TaskSummaryEnumField.SessionId,
                                                                       FilterStringOperator.Equal,
                                                                       string.Empty));
+    yield return CaseTrue(ListTasksHelper.CreateListTasksFilterString(TaskSummaryEnumField.PayloadId,
+                                                                      FilterStringOperator.Equal,
+                                                                      string.Empty));
     yield return CaseTrue(ListTasksHelper.CreateListTasksFilterString(TaskSummaryEnumField.PodHostname,
                                                                       FilterStringOperator.Equal,
                                                                       string.Empty));

diff --git a/Tests/Bench/Server/src/ArmoniK.Samples.Bench.Server.csproj b/Tests/Bench/Server/src/ArmoniK.Samples.Bench.Server.csproj
@@ -25,7 +25,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="ArmoniK.Api.Worker" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Worker" Version="3.19.0" />
     <PackageReference Include="ArmoniK.Utils.Diagnostics" Version="0.5.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/Tests/Common/Client/src/ArmoniK.Core.Common.Client.csproj b/Tests/Common/Client/src/ArmoniK.Core.Common.Client.csproj
@@ -25,7 +25,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="ArmoniK.Api.Client" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Client" Version="3.19.0" />
     <PackageReference Include="ArmoniK.Utils.Diagnostics" Version="0.5.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/Tests/Connectivity/src/ArmoniK.Core.Tests.Connectivity.csproj b/Tests/Connectivity/src/ArmoniK.Core.Tests.Connectivity.csproj
@@ -25,7 +25,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="ArmoniK.Api.Client" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Client" Version="3.19.0" />
     <PackageReference Include="ArmoniK.Utils.Diagnostics" Version="0.5.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/Tests/CrashingWorker/Client/src/ArmoniK.Samples.CrashingWorker.Client.csproj b/Tests/CrashingWorker/Client/src/ArmoniK.Samples.CrashingWorker.Client.csproj
@@ -35,7 +35,7 @@
     <PackageReference Include="Serilog.Settings.Configuration" Version="8.0.0" />
     <PackageReference Include="Serilog.Sinks.Console" Version="5.0.1" />
     <PackageReference Include="Serilog.Formatting.Compact" Version="2.0.0" />
-    <PackageReference Include="ArmoniK.Api.Client" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Client" Version="3.19.0" />
   </ItemGroup>
 
   <ItemGroup>

diff --git a/Tests/CrashingWorker/Server/src/ArmoniK.Samples.CrashingWorker.Server.csproj b/Tests/CrashingWorker/Server/src/ArmoniK.Samples.CrashingWorker.Server.csproj
@@ -26,7 +26,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="ArmoniK.Api.Worker" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Worker" Version="3.19.0" />
     <PackageReference Include="ArmoniK.Utils.Diagnostics" Version="0.5.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/Tests/HtcMock/Server/src/ArmoniK.Samples.HtcMock.Server.csproj b/Tests/HtcMock/Server/src/ArmoniK.Samples.HtcMock.Server.csproj
@@ -26,7 +26,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="ArmoniK.Api.Worker" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Worker" Version="3.19.0" />
     <PackageReference Include="ArmoniK.Utils.Diagnostics" Version="0.5.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/Tests/Stream/Client/ArmoniK.Extensions.Common.StreamWrapper.Tests.Client.csproj b/Tests/Stream/Client/ArmoniK.Extensions.Common.StreamWrapper.Tests.Client.csproj
@@ -25,7 +25,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="ArmoniK.Api.Client" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Client" Version="3.19.0" />
     <PackageReference Include="ArmoniK.Utils.Diagnostics" Version="0.5.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>

diff --git a/Tests/Stream/Server/ArmoniK.Extensions.Common.StreamWrapper.Tests.Server.csproj b/Tests/Stream/Server/ArmoniK.Extensions.Common.StreamWrapper.Tests.Server.csproj
@@ -24,7 +24,7 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="ArmoniK.Api.Worker" Version="3.18.1" />
+    <PackageReference Include="ArmoniK.Api.Worker" Version="3.19.0" />
     <PackageReference Include="ArmoniK.Utils.Diagnostics" Version="0.5.1">
       <PrivateAssets>all</PrivateAssets>
       <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>