feat(runtime): DriverHost spawns + subscribes only its own ClusterId's drivers

2026-06-07 03:19:22 -04:00
parent 4fca4e1aca
commit 1b7f995aea
2 changed files with 82 additions and 2 deletions
@@ -364,7 +364,7 @@ public sealed class DriverHostActor : ReceiveActor, IWithTimers
            return;
        }

-        var specs = DeploymentArtifact.ParseDriverInstances(blob);
+        var specs = DeploymentArtifact.ParseDriverInstances(blob, _localNode.Value);
        var snapshots = _children.ToDictionary(
            kv => kv.Key,
            kv => new DriverChildSnapshot(kv.Value.DriverType, kv.Value.LastConfigJson),
@@ -429,7 +429,7 @@ public sealed class DriverHostActor : ReceiveActor, IWithTimers
        Phase7CompositionResult composition;
        try
        {
-            composition = DeploymentArtifact.ParseComposition(blob);
+            composition = DeploymentArtifact.ParseComposition(blob, _localNode.Value);
        }
        catch (Exception ex)
        {