1 instantiation of Executable
Aspire.Hosting (1)
Dcp\Model\Executable.cs (1)
293var exe = new Executable(new ExecutableSpec
331 references to Executable
Aspire.Hosting (52)
Dcp\DcpExecutor.cs (11)
164RenderedModelResource<Executable>[] executables; 346Executable => appModelResource.GetResourceType(), 758private void AllocateExecutableTargetPorts(IEnumerable<RenderedModelResource<Executable>> executables) 1071Executable exe => s => _resourceWatcher.SnapshotBuilder.ToSnapshot(exe, s), 1107Executable { Spec.Start: false } => true, 1200case Executable e: 1203var eu = await _kubernetesService.GetAsync<Executable>(e.Metadata.Name, cancellationToken: attemptCancellationToken).ConfigureAwait(false); 1262case RenderedModelResource<Executable> { DcpResource.Spec.Start: false } er when !DcpModelUtilities.ShouldDeferCreateForExplicitStart(er.ModelResource, er.DcpResource.Spec.Start): 1280case RenderedModelResource<Executable> er: 1281await 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.Blazor.Tests (3)
AddBlazorGatewayTests.cs (3)
556var executable = Executable.Create("gateway-12345678", "stale"); 557var renderedResource = new RenderedModelResource<Executable>(resource, executable);
Aspire.Hosting.Dotnet.Tests (1)
DotnetProjectResourceTests.cs (1)
123var executable = rendered[index];
Aspire.Hosting.Tests (275)
Dcp\DcpExecutorTests.cs (218)
80var previous = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "program")); 85var replacement = GetCreatedExecutablesForResource(kubernetesService, "program").Last(); 106if (resource is Executable { AppModelResourceName: "program" } && 115if (context is { EventType: k8s.WatchEventType.Deleted, Resource: Executable { AppModelResourceName: "program" } }) 120if (context.Resource is Executable { Status.ExitCode: 7 }) 150var previous = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "program")); 183var replacement = GetCreatedExecutablesForResource(kubernetesService, "program").Last(); 207if (resource is Executable { AppModelResourceName: "program" } && 242var previous = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "program")); 306foreach (var executable in executables) 393var executable = GetCreatedExecutableForResource(kubernetesService, "program"); 574var exe = Assert.Single(executables); 609var executables = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 610var exe = Assert.Single(executables); 662var exe = GetCreatedExecutableForResource(kubernetesService, "tool"); 702var exe = GetCreatedExecutableForResource(kubernetesService, "tool"); 737var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 935var exe1 = Assert.Single(executables); 955var exe2 = executables[1]; 988var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1026var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1057var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1098var fixedExecutable = kubernetesService.CreatedResources.OfType<Executable>().Single(e => e.AppModelResourceName == "FixedProgram"); 1099var dynamicExecutable = kubernetesService.CreatedResources.OfType<Executable>().Single(e => e.AppModelResourceName == "DynamicProgram"); 1122var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1177var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1206var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1241var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1284var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1322var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1350var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1381var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1413var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1443var dcpExe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>()); 1565var dynamicExecutable = kubernetesService.CreatedResources.OfType<Executable>().Single(e => e.AppModelResourceName == "DynamicProgram"); 1721var firstExecutable = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "CoolProgram")); 1923foreach (var exe in executables) 3102async Task PublishStateAsync(Executable executable, string state, string? previousState) 3947foreach (var dcpExe in exes) 3994foreach (var dcpExe in exes) 4033var dcpExe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 4070var dcpExe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 4115var dcpExe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 4993var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5027var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5069var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5105var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5141var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5177var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5208var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5239var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5269var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5298var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5363var executable = GetCreatedExecutableForResource(kubernetesService, resource.Name); 5405List<Executable> dcpExes = []; 5409dcpExes.AddRange(kubernetesService.CreatedResources.OfType<Executable>()); 5414var debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 5417Assert.True(debuggableExe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs1)); 5422var nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable"); 5424Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 5455var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "TestExecutable"); 5484var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5521var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5547var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5590var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5630var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5674var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5718var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5804var exe = GetCreatedExecutableForResource(kubernetes, "proj"); 5842var executables = kubernetesService.CreatedResources.OfType<Executable>() 5996var executables = kubernetesService.CreatedResources.OfType<Executable>() 6042var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "TestExecutable"); 6142var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "TestExecutable"); 6241var exe = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "CoolProgram")); 6319var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6322var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6356var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6359var debuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6361Assert.False(debuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 6363var nonDebuggableExe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestOtherExecutable"); 6365Assert.False(nonDebuggableExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out _)); 6397var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6400var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6433var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6436var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6475var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6478var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6517var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6520var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6559var dcpExes = kubernetesService.CreatedResources.OfType<Executable>().ToList(); 6562var exe = Assert.Single(dcpExes, e => e.AppModelResourceName == "TestExecutable"); 6595var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6635var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6675var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6708var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6747var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6788var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 6823var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 6828Assert.True(exe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 6871var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 6930var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 6982var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7027var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7098var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7112Assert.True(exe.TryGetAnnotationAsObjectList<TestMauiLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 7202var executable = GetCreatedExecutableForResource(kubernetesService, "proj"); 7220Executable.LaunchConfigurationsAnnotation, 7346var executable = GetCreatedExecutableForResource(kubernetesService, "proj"); 7367Executable.LaunchConfigurationsAnnotation, 7429var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7519var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7634var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7687var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7752var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7779var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7821var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 7860var standardExe = GetCreatedExecutableForResource(kubernetesService, "standard-project"); 7863var customExe = GetCreatedExecutableForResource(kubernetesService, "custom-project"); 7868Assert.True(customExe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 7919var standardExe = GetCreatedExecutableForResource(kubernetesService, "standard-project"); 7923var functionsExe = GetCreatedExecutableForResource(kubernetesService, "functions-project"); 7958var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 8039var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8043Assert.True(exe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 8079var exe = GetCreatedExecutableForResource(kubernetesService, "file-project"); 8130var exe = GetCreatedExecutableForResource(kubernetesService, "file-project"); 8176var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8217var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 8219Assert.True(exe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 8298var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8337var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8374var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8410var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8445var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8496var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8534var exe = GetCreatedExecutableForResource(kubernetesService, "ServiceA"); 8569var exe = GetCreatedExecutableForResource(kubernetesService, "TestFunction"); 8573Assert.True(exe.TryGetAnnotationAsObjectList<ProjectLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 8608var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 8643var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 8662var dcpExecutable = Executable.Create("test-exe", "dotnet"); 8707var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 8739var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 8784Assert.Empty(kubernetesService.CreatedResources.OfType<Executable>()); 8833var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 8888var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 8939var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 8992var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 9025var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 9069var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 9158var exe = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "TestExecutable")); 9200var exe = GetCreatedExecutableForResource(kubernetesService, "TestExecutable"); 9237var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 9362var executable = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "TestDotnetProject")); 9431var exe1 = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "TestExecutable")); 9441var exe2 = executables[1]; 9450var exe3 = executables[2]; 9493var exe1 = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "TestExecutable")); 9512var exe2 = executables[1]; 9552Assert.Empty(kubernetesService.CreatedResources.OfType<Executable>()); 9588var exe = GetCreatedExecutableForResource(kubernetesService, "TestDotnetProject"); 9929var startedExecutable = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "anExecutable"), e => e.Spec.Start == true); 10019var executable = Assert.Single(GetCreatedExecutablesForResource(kubernetesService, "anExecutable")); 10227var dcpExecutable = Assert.Single( 10228kubernetesService.CreatedResources.OfType<Executable>(), 10277var sourceExecutable = Assert.Single( 10278kubernetesService.CreatedResources.OfType<Executable>(), 10314var dcpExecutable = Assert.Single( 10315kubernetesService.CreatedResources.OfType<Executable>(), 10354var sourceExecutable = Assert.Single( 10355kubernetesService.CreatedResources.OfType<Executable>(), 10407kubernetesService.CreatedResources.OfType<Executable>(), 10410kubernetesService.CreatedResources.OfType<Executable>(), 10474kubernetesService.CreatedResources.OfType<Executable>(), 10477kubernetesService.CreatedResources.OfType<Executable>(), 10514var sourceExecutable = Assert.Single( 10515kubernetesService.CreatedResources.OfType<Executable>(), 10563var dcpExecutable = Assert.Single( 10564kubernetesService.CreatedResources.OfType<Executable>(), 10763while (!kubernetesService.CreatedResources.OfType<Executable>().Any(e => e.AppModelResourceName == upstreamExecutable.Resource.Name)) 10787var upstreamExecutableResource = Assert.Single(createdResources.OfType<Executable>(), e => e.AppModelResourceName == upstreamExecutable.Resource.Name); 10788var downstreamExecutableResource = Assert.Single(createdResources.OfType<Executable>(), e => e.AppModelResourceName == downstreamExecutable.Resource.Name); 11002var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 11006Assert.True(exe.TryGetAnnotationAsObjectList<ExecutableLaunchConfiguration>(Executable.LaunchConfigurationsAnnotation, out var launchConfigs)); 11055Assert.Empty(kubernetesService.CreatedResources.OfType<Executable>()); 11094var exe = GetCreatedExecutableForResource(kubernetesService, "proj"); 11109private static Executable GetCreatedExecutableForResource(TestKubernetesService kubernetesService, string appModelResourceName) 11114private static List<Executable> GetCreatedExecutablesForResource(TestKubernetesService kubernetesService, string appModelResourceName) 11117.OfType<Executable>() 11159var exes = kubernetesService.CreatedResources.OfType<Executable>() 11197var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "ServiceA"); 11230var exe = Assert.Single(kubernetesService.CreatedResources.OfType<Executable>(), e => e.AppModelResourceName == "shell"); 11511var 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)