This is an automated email from the ASF dual-hosted git repository. ptupitsyn pushed a commit to branch ignite-27278 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
commit 741c2a896c5304b9ffa0ce56112fb9e1e59a9562 Author: Pavel Tupitsyn <[email protected]> AuthorDate: Wed Dec 24 14:45:22 2025 +0200 wip AOT tests: TestColocatedPoco --- .../Apache.Ignite.Tests.Aot/Compute/ComputeTests.cs | 19 +++++++++++++++++-- 1 file changed, 17 insertions(+), 2 deletions(-) diff --git a/modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Compute/ComputeTests.cs b/modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Compute/ComputeTests.cs index bda39ea0ce3..a971338ff84 100644 --- a/modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Compute/ComputeTests.cs +++ b/modules/platforms/dotnet/Apache.Ignite.Tests.Aot/Compute/ComputeTests.cs @@ -18,6 +18,7 @@ namespace Apache.Ignite.Tests.Aot.Compute; using Common.Compute; +using Common.Table; using Ignite.Compute; using Ignite.Table; using JetBrains.Annotations; @@ -42,7 +43,20 @@ public class ComputeTests(IIgniteClient client) { var keyTuple = new IgniteTuple { [KeyCol] = 42L }; - IJobExecution<string> exec = await client.Compute.SubmitAsync(JobTarget.Colocated(TableName, keyTuple), JavaJobs.NodeNameJob, null); + IJobTarget<IgniteTuple> jobTarget = JobTarget.Colocated(TableName, keyTuple); + IJobExecution<string> exec = await client.Compute.SubmitAsync(jobTarget, JavaJobs.NodeNameJob, null); + var res = await exec.GetResultAsync(); + + Assert.AreEqual(JavaJobs.PlatformTestNodeRunner, res); + } + + [UsedImplicitly] + public async Task TestColocatedPoco() + { + var key = new Poco { Key = 42L }; + + IJobTarget<Poco> jobTarget = JobTarget.Colocated(TableName, key, new PocoMapper()); + IJobExecution<string> exec = await client.Compute.SubmitAsync(jobTarget, JavaJobs.NodeNameJob, null); var res = await exec.GetResultAsync(); Assert.AreEqual(JavaJobs.PlatformTestNodeRunner, res); @@ -53,7 +67,8 @@ public class ComputeTests(IIgniteClient client) { try { - await client.Compute.SubmitAsync(JobTarget.Colocated(TableName, 42L), JavaJobs.NodeNameJob, null); + IJobTarget<long> jobTarget = JobTarget.Colocated(TableName, 42L); + await client.Compute.SubmitAsync(jobTarget, JavaJobs.NodeNameJob, null); throw new Exception("Expected exception was not thrown."); } catch (InvalidOperationException e)
