27using TestConstants = Microsoft.AspNetCore.InternalTesting.TestConstants; 65}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 106}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 133var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 136await orchestrator.StartResourceAsync(resourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 137await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 140await orchestrator.StopResourceAsync(resourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 141await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 144var restartResourceTask = orchestrator.StartResourceAsync(resourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 145await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 148await orchestrator.StartResourceAsync(resourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 149await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 151await restartResourceTask.DefaultTimeout(TestConstants.LongTimeoutDuration); 152await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 153await app.StopAsync().DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 177var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 178var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 198await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 199var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 207var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 215await orchestrator.StopResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 216await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 219await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 220await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 222await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 223await app.StopAsync().DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 252var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 253var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 272await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 273var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 280var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 288await orchestrator.StopResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 289await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 292await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 293await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 295await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 296await app.StopAsync().DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 333notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 334dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 353await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 356var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 363var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 371await orchestrator.StopResourceAsync(runningResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 372await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 378await orchestrator.StartResourceAsync(runningResourceEvent.ResourceId, CancellationToken.None).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 379await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 382await startTask.DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 383await app.StopAsync().DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 434await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 436var appModel = await tcs.Task.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 472await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 478await Task.WhenAll(clientA.GetStringAsync("/pid"), clientC.GetStringAsync("/pid")).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 526await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 529var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 539await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 584await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 587var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 605await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 633await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 635using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestLongTimeout); 639var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 645await orchestrator.StopResourceAsync(redisContainer.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 647redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 658await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 676await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 679var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 682await orchestrator.StopResourceAsync(serviceA.Metadata.Name, CancellationToken.None).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 684serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 687await orchestrator.StartResourceAsync(serviceA.Metadata.Name, CancellationToken.None).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 689serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running).DefaultTimeout(TestConstants.LongTimeoutDuration); 692await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 718await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 721var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 724var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 727var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 744await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 773await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 776var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 786await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 813await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 816var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 822await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 844await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 850r => r.Status?.State == ContainerState.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 856await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 873await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 880$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 886await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 902await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 909$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 916await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 932await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 939$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 945await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 958await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 977await foreach (var resource in s.WatchAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 991await foreach (var resource in s.WatchAsync<Executable>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1019var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1038var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1060await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1064var result = await client.GetStringAsync("pid").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1076}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1103await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1105using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 1109await app.WaitForTextAsync("Content root path:", resourceName: testProgram.ServiceABuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutDuration); 1172await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1175await app.WaitForTextAsync("Application started.").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1179await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1202await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1226await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1229await app.WaitForTextAsync("Application started.").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1233await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1260await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1277var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1300await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1332await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1334await kubernetesLifecycle.HooksCompleted.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

189await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 193await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 216await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 221await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 327await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

48await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 224var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 241await app.StopAsync(abortTokenSource.Token).TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 265var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 308var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 357await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 423var pendingStart = app.StartAsync().DefaultTimeout(TestConstants.LongTimeoutDuration); 557await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 605await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 651await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan);

103await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 105await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 109await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 111await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 113await pendingStart.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 115await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 135}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

31await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 33var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 35await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 60await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 62var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 64await app.StopAsync().WaitAsync(TestConstants.LongTimeoutTimeSpan); 89await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 91var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 93await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 120await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 122var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 124await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan);

34using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 64using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 102using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 140using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 174using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 211using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 251using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 290using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 326using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 355using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 405using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 432using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 458using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 480using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 501using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 531using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 563using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 595using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 632using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan);

133await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 176await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 235await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 270await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

26using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 51using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 70using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration);

32using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration);

40milliseconds = TestConstants.DefaultTimeoutDuration; 55milliseconds = TestConstants.DefaultTimeoutDuration; 70milliseconds = TestConstants.DefaultTimeoutDuration; 85milliseconds = TestConstants.DefaultTimeoutDuration; 100milliseconds = TestConstants.DefaultTimeoutDuration; 115milliseconds = TestConstants.DefaultTimeoutDuration;

28var abortCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 103using var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 106using var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 134using var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 137using var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 167var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 173var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 211var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 214var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 322var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 325var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 356var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 359var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 403var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 406var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 445var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 451var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 467var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 492var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 498var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 514var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 547var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 553var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 570var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 601var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 607var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 622var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 652var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 658var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 705var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 711var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 754var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 760var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 869var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 873var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 883var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration);

188await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 212await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 235await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 274await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 313await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 354await app.ResourceNotifications.WaitForResourceHealthyAsync("servicea").DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 403await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Starting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 413await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 414await watchTcs.Task.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 473await app.ResourceNotifications.WaitForResourceAsync(service.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 484await watchTcs.Task.DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

343await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 379await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 428await app.ResourceNotifications.WaitForResourceAsync(servicea.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 430await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 592await app.ResourceNotifications.WaitForResourceAsync(servicea.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 593await app.ResourceNotifications.WaitForResourceAsync(custom.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 595await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 636await rns.WaitForResourceAsync("servicea", KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 637await watchTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan);