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
The following commit(s) were added to refs/heads/ignite-27278 by this push:
new eee4702c8df wip TestExecuteColocated
eee4702c8df is described below
commit eee4702c8dfe2e245aa9e8a38bf137df7abf0a35
Author: Pavel Tupitsyn <[email protected]>
AuthorDate: Wed Dec 24 14:32:33 2025 +0200
wip TestExecuteColocated
---
modules/platforms/dotnet/Apache.Ignite.Tests/Compute/ComputeTests.cs | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/modules/platforms/dotnet/Apache.Ignite.Tests/Compute/ComputeTests.cs
b/modules/platforms/dotnet/Apache.Ignite.Tests/Compute/ComputeTests.cs
index 023308a360d..7e018f422b5 100644
--- a/modules/platforms/dotnet/Apache.Ignite.Tests/Compute/ComputeTests.cs
+++ b/modules/platforms/dotnet/Apache.Ignite.Tests/Compute/ComputeTests.cs
@@ -279,12 +279,16 @@ namespace Apache.Ignite.Tests.Compute
var resNodeName3 = await
client.Compute.SubmitAsync(JobTarget.Colocated(TableName, keyPocoStruct),
NodeNameJob, null);
var requestTargetNodeName3 = GetRequestTargetNodeName(proxies,
ClientOp.ComputeExecuteColocated);
+ var resNodeName4 = await
client.Compute.SubmitAsync(JobTarget.Colocated(QualifiedName.Parse(TableName),
keyPoco, new PocoMapper()), NodeNameJob, null);
+ var requestTargetNodeName4 = GetRequestTargetNodeName(proxies,
ClientOp.ComputeExecuteColocated);
+
var nodeName = nodeIdx == 1 ? string.Empty : "_" + nodeIdx;
var expectedNodeName = PlatformTestNodeRunner + nodeName;
Assert.AreEqual(expectedNodeName, await
resNodeName.GetResultAsync());
Assert.AreEqual(expectedNodeName, await
resNodeName2.GetResultAsync());
Assert.AreEqual(expectedNodeName, await
resNodeName3.GetResultAsync());
+ Assert.AreEqual(expectedNodeName, await
resNodeName4.GetResultAsync());
// We only connect to 2 of 4 nodes because of different auth
settings.
if (nodeIdx < 3)
@@ -292,6 +296,7 @@ namespace Apache.Ignite.Tests.Compute
Assert.AreEqual(expectedNodeName, requestTargetNodeName);
Assert.AreEqual(expectedNodeName, requestTargetNodeName2);
Assert.AreEqual(expectedNodeName, requestTargetNodeName3);
+ Assert.AreEqual(expectedNodeName, requestTargetNodeName4);
}
}