1 instantiation of Executable
Aspire.Hosting (1)
Dcp\Model\Executable.cs (1)
293var exe = new Executable(new ExecutableSpec
328 references to Executable
Aspire.Hosting (52)
Dcp\DcpExecutor.cs (11)
165RenderedModelResource<Executable>[] executables; 347Executable => appModelResource.GetResourceType(), 759private void AllocateExecutableTargetPorts(IEnumerable<RenderedModelResource<Executable>> executables) 1072Executable exe => s => _resourceWatcher.SnapshotBuilder.ToSnapshot(exe, s), 1108Executable { Spec.Start: false } => true, 1201case Executable e: 1204var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1263case RenderedModelResource<Executable> { DcpResource.Spec.Start: false } er when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(er.ModelResource, er.DcpResource.Spec.Start): 1281case RenderedModelResource<Executable> er: 1282await EnsureResourceDeletedAsync<Executable>(resourceReference, cancellationToken).ConfigureAwait(false);
Dcp\DcpModelUtilities.cs (2)
101if (resource is Executable exe && exe.Metadata.Annotations.TryGetValue(CustomResource.ResourceReplicaCount, out var value) && int.TryParse(value, CultureInfo.InvariantCulture, out var replicas) && replicas > 1) 254if (resource.DcpResource is not Executable || enableAspireContainerTunnel)
Dcp\DcpResourceState.cs (1)
13public readonly ConcurrentDictionary<string, Executable> ExecutablesMap = [];
Dcp\DcpResourceWatcher.cs (9)
155Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, Model.Dcp.ExecutableKind, (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 206else if (_resourceState.ExecutablesMap.TryGetValue(entry.ResourceName, out var executable)) 549resource is Executable { LogsAvailable: true } || 565if (resource is Executable executable) 607else if (_resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable)) 609enumerable = new ResourceLogSource<Executable>(_logger, _kubernetesService, executable, follow: false); 653Executable e when e.LogsAvailable => new ResourceLogSource<T>(_logger, _kubernetesService, resource, follow: true), 998"Executable" => _resourceState.ExecutablesMap.TryGetValue(resourceName, out var executable) ? executable : null, 1026else if (cr is Executable exe)
Dcp\ExecutableConfigurationResolver.cs (4)
32RenderedModelResource<Executable> renderedResource, 37var executable = renderedResource.DcpResource; 169RenderedModelResource<Executable> renderedResource, 170Executable executable)
Dcp\ExecutableCreator.cs (19)
25ILogger<ExecutableCreator> logger) : IObjectCreator<Executable, ContainerNetworkEndpointContext> 37public IEnumerable<RenderedModelResource<Executable>> PrepareObjects(CancellationToken cancellationToken) 42return _appResources.Get().OfType<RenderedModelResource<Executable>>(); 46RenderedModelResource<Executable> resource, 53RenderedModelResource<Executable> renderedResource, 133.OfType<RenderedModelResource<Executable>>() 236RenderedModelResource<Executable> renderedResource, 241var executable = renderedResource.DcpResource; 261executable.Metadata.Annotations?.Remove(Executable.LaunchConfigurationsAnnotation); 264executable.SetAnnotationAsObjectList(Executable.LaunchConfigurationsAnnotation, plan.LaunchConfigurations); 296var executable = Executable.Create(instance.Name, executableAnnotation?.Command ?? "dotnet"); 324var executable = Executable.Create(instance.Name, resource.Command); 336Executable executable, 376private static void ApplyTerminal(IResource resource, Executable executable, ILogger logger) 405private static bool TryGetReplicaIndex(Executable executable, out int replicaIndex) 419private void AddRenderedResource(IResource resource, Executable executable) 421var renderedResource = new RenderedModelResource<Executable>(resource, executable);
Dcp\Model\Executable.cs (2)
291public static Executable Create(string name, string executablePath) 293var exe = new Executable(new ExecutableSpec
Dcp\Model\GroupVersion.cs (1)
36Schema.Add<Executable>(ExecutableKind, "executables");
Dcp\ResourceLogSource.cs (2)
57IReadOnlyList<KeyValuePair<string, string?>>? systemLogFields = resource is Executable executable 127if (resource is not Executable { Spec.Terminal: not null })
Dcp\ResourceSnapshotBuilder.cs (1)
133public CustomResourceSnapshot ToSnapshot(Executable executable, CustomResourceSnapshot previous)
Aspire.Hosting.Dotnet.Tests (1)
DotnetProjectResourceTests.cs (1)
125var executable = rendered[index];
Aspire.Hosting.Tests (275)
Dcp\DcpExecutorTests.cs (218)
81var previous = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "program")); 86var replacement = GetCreatedExecutablesForResource(kubernetesService, "program").Last(); 107if (resource is Executable { AppModelResourceName: "program" } && 116if (context is { EventType: k8s.WatchEventType.Deleted, Resource: Executable { AppModelResourceName: "program" } }) 121if (context.Resource is Executable { Status.ExitCode: 7 }) 151var previous = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "program")); 184var replacement = GetCreatedExecutablesForResource(kubernetesService, "program").Last(); 208if (resource is Executable { AppModelResourceName: "program" } && 243var previous = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "program")); 307foreach (var executable in executables) 394var executable = GetCreatedExecutableForResource(kubernetesService, "program"); 575var exe = Assert.Single(executables); 610var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 611var exe = Assert.Single(executables); 663var exe = GetCreatedExecutableForResource(kubernetesService, "tool"); 703var exe = GetCreatedExecutableForResource(kubernetesService, "tool"); 738var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 936var exe1 = Assert.Single(executables); 956var exe2 = executables[1]; 989var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1027var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1058var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1099var fixedExecutable = kubernetesService.CreatedResources.OfType<Executable>().Single(e => e.AppModelResourceName == "FixedProgram"); 1100var dynamicExecutable = kubernetesService.CreatedResources.OfType<Executable>().Single(e => e.AppModelResourceName == "DynamicProgram"); 1123var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1178var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1207var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1242var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1285var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1323var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1351var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1382var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1414var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1444var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1566var dynamicExecutable = kubernetesService.CreatedResources.OfType<Executable>().Single(e => e.AppModelResourceName == "DynamicProgram"); 1722var firstExecutable = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "CoolProgram")); 1924foreach (var exe in executables) 3103async Task PublishStateAsync(Executable executable, string state, string? previousState) 3948foreach (var dcpExe in exes) 3995foreach (var dcpExe in exes) 4034var dcpExe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 4071var dcpExe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 4116var dcpExe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 4994var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5028var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5070var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5106var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5142var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5178var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5209var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5240var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5270var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5299var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5364var executable = GetCreatedExecutableForResource(kubernetesService, resource.Name); 5406List<Executable> dcpExes = []; 5410dcpExes.AddRange(kubernetesService.CreatedResources.OfType<Executable>()); 5415var debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 5418Assert.True(debuggableExe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs1)); 5423var nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable"); 5425Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 5456var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "TestExecutable"); 5485var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5522var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5548var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5591var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5631var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5675var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5719var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5805var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5843var executables = kubernetesService.CreatedResources.OfType<Executable>() 5997var executables = kubernetesService.CreatedResources.OfType<Executable>() 6043var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "TestExecutable"); 6143var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "TestExecutable"); 6242var exe = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "CoolProgram")); 6320var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6323var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6357var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6360var debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6362Assert.False(debuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 6364var nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable"); 6366Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 6398var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6401var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6434var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6437var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6476var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6479var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6518var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6521var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6560var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6563var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6596var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6636var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6676var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6709var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6748var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6789var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6824var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 6829Assert.True(exe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 6872var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 6931var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 6983var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7028var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7099var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7113Assert.True(exe.TryGetAnnotationAsObjectList<TestMauiLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 7203var executable = GetCreatedExecutableForResource(kubernetesService, "proj"); 7221Executable.LaunchConfigurationsAnnotation, 7347var executable = GetCreatedExecutableForResource(kubernetesService, "proj"); 7368Executable.LaunchConfigurationsAnnotation, 7430var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7520var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7635var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7688var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7753var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7780var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7822var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7861var standardExe = GetCreatedExecutableForResource(kubernetesService, "standard-project"); 7864var customExe = GetCreatedExecutableForResource(kubernetesService, "custom-project"); 7869Assert.True(customExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 7920var standardExe = GetCreatedExecutableForResource(kubernetesService, "standard-project"); 7924var functionsExe = GetCreatedExecutableForResource(kubernetesService, "functions-project"); 7959var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 8040var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8044Assert.True(exe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 8080var exe = GetCreatedExecutableForResource(kubernetesService, "file-project"); 8131var exe = GetCreatedExecutableForResource(kubernetesService, "file-project"); 8177var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8218var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 8220Assert.True(exe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 8299var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8338var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8375var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8411var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8446var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8497var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8535var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8570var exe = GetCreatedExecutableForResource(kubernetesService, "TestFunction"); 8574Assert.True(exe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 8609var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 8644var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 8663var dcpExecutable = Executable.Create("test-exe", "dotnet"); 8708var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 8740var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 8785Assert.Empty(kubernetesService.CreatedResources.OfType<Executable>()); 8834var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 8889var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 8940var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 8993var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 9026var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 9070var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 9159var exe = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "TestExecutable")); 9201var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 9238var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 9363var executable = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "TestDotnetProject")); 9432var exe1 = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "TestExecutable")); 9442var exe2 = executables[1]; 9451var exe3 = executables[2]; 9494var exe1 = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "TestExecutable")); 9513var exe2 = executables[1]; 9553Assert.Empty(kubernetesService.CreatedResources.OfType<Executable>()); 9589var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 9930var startedExecutable = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "anExecutable"), e => e.Spec.Start == true); 10020var executable = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "anExecutable")); 10202var dcpExecutable = Assert.Single( 10203kubernetesService.CreatedResources.OfType<Executable>(), 10252var sourceExecutable = Assert.Single( 10253kubernetesService.CreatedResources.OfType<Executable>(), 10289var dcpExecutable = Assert.Single( 10290kubernetesService.CreatedResources.OfType<Executable>(), 10329var sourceExecutable = Assert.Single( 10330kubernetesService.CreatedResources.OfType<Executable>(), 10382kubernetesService.CreatedResources.OfType<Executable>(), 10385kubernetesService.CreatedResources.OfType<Executable>(), 10449kubernetesService.CreatedResources.OfType<Executable>(), 10452kubernetesService.CreatedResources.OfType<Executable>(), 10489var sourceExecutable = Assert.Single( 10490kubernetesService.CreatedResources.OfType<Executable>(), 10538var dcpExecutable = Assert.Single( 10539kubernetesService.CreatedResources.OfType<Executable>(), 10738while (!kubernetesService.CreatedResources.OfType<Executable>().Any(e => e.AppModelResourceName == upstreamExecutable.Resource.Name)) 10762var upstreamExecutableResource = Assert.Single(createdResources.OfType<Executable>(), e => e.AppModelResourceName == upstreamExecutable.Resource.Name); 10763var downstreamExecutableResource = Assert.Single(createdResources.OfType<Executable>(), e => e.AppModelResourceName == downstreamExecutable.Resource.Name); 10977var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 10981Assert.True(exe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 11030Assert.Empty(kubernetesService.CreatedResources.OfType<Executable>()); 11069var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 11084private static Executable GetCreatedExecutableForResource(TestKubernetesService kubernetesService, string appModelResourceName) 11089private static List<Executable> GetCreatedExecutablesForResource(TestKubernetesService kubernetesService, string appModelResourceName) 11092.OfType<Executable>() 11134var exes = kubernetesService.CreatedResources.OfType<Executable>() 11172var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "ServiceA"); 11205var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "shell"); 11486var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "TestExecutable");
Dcp\ExecutableLaunchPlanTests.cs (4)
206var executable = Executable.Create("app-12345678", "stale-tool"); 210var renderedResource = new RenderedModelResource<Executable>(resource, executable); 234Assert.False(executable.Metadata.Annotations?.ContainsKey(Executable.LaunchConfigurationsAnnotation) is true);
Dcp\ResourceLogSourceTests.cs (6)
26var executable = Executable.Create("app", "dotnet"); 42var logSource = new ResourceLogSource<Executable>( 66var executable = Executable.Create("terminal-executable", "command"); 85var logSource = new ResourceLogSource<Executable>(
Dcp\ResourceSnapshotBuilderTests.cs (23)
45var executable = Executable.Create("exe", "dotnet"); 67var executable = Executable.Create("project", "dotnet"); 99var executable = Executable.Create(resource.Name, "python"); 132var executable = Executable.Create("project", "dotnet"); 160var executable = Executable.Create("proj", "dotnet"); 185var executable = CreateExecutable( 203var executable = CreateExecutable( 218var executable = Executable.Create("exe", "pwsh"); 233var executable = Executable.Create("exe", "pwsh"); 248var executable = Executable.Create("exe", "pwsh"); 263var executable = Executable.Create("exe", "pwsh"); 275private static Executable CreateExecutable(AppLaunchArgumentAnnotation[] launchArgumentAnnotations, IReadOnlyList<string> effectiveArgs) 277var executable = Executable.Create("exe", "pwsh");
Dcp\TestKubernetesService.cs (2)
406if (res is Executable exe && result is Executable eu)
DistributedApplicationTests.cs (22)
1269var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1276serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1281serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration); 1314var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1317var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1392var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1429var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1665await foreach (var resource in s.WatchAsync<Executable>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1667Assert.True(resource.Item2.Metadata.Annotations.TryGetValue(Executable.ResourceNameAnnotation, out var value)); 1858var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1860var service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName)); 1936var exeList = await s.ListAsync<Executable>().DefaultTimeout(); 1938var service = Assert.Single(exeList, c => $"{testName}-servicea".Equals(c.AppModelResourceName)); 2072var executables = await kubernetes.ListAsync<Executable>(cancellationToken: token) 2074var dcpExecutable = Assert.Single(executables, e => e.AppModelResourceName == executable.Resource.Name); 2248var worker = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, workerNamePattern, r => r.Status?.State == ContainerState.Running, token)