282await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 298await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 313await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 323await socket.ConnectAsync(endpoint).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 334).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 339await app.StopAsync().WaitAsync(TestConstants.LongTimeoutTimeSpan); 354await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 364await socket.ConnectAsync(endpoint).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 375).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 380await app.StopAsync().WaitAsync(TestConstants.LongTimeoutTimeSpan); 391await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 401await socket.ConnectAsync(endpoint).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 410).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 418using var cts = new CancellationTokenSource(TestConstants.DefaultTimeoutTimeSpan); 440await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 450await socket.ConnectAsync(endpoint).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 459).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 467await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 478await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 488await socket.ConnectAsync(endpoint).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 497).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 507await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 521await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 531await socket.ConnectAsync(endpoint).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 540).WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 550await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan);

256await resourcesCreatedTcs.Task.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 259await pendingRun.DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

34await app.StartAsync().DefaultTimeout(TestConstants.ExtraLongTimeoutDuration); 35await app.WaitForTextAsync("Application started.").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 38var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 40var body = await response.Content.ReadAsStringAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 43await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 73await app.StartAsync().DefaultTimeout(TestConstants.ExtraLongTimeoutDuration); 74await app.WaitForTextAsync("Application started.").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 77var response = await clientA.GetAsync("/servicea/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 79var body = await response.Content.ReadAsStringAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 82await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);

1691}, TestConstants.DefaultOrchestratorTestTimeout);

29using TestConstants = Microsoft.AspNetCore.InternalTesting.TestConstants; 72}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 117}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 140using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 145var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 148await orchestrator.StartResourceAsync(resourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 149await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 152await orchestrator.StopResourceAsync(resourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 153await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 156var restartResourceTask = orchestrator.StartResourceAsync(resourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 157await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 160await orchestrator.StartResourceAsync(resourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 161await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 163await restartResourceTask.DefaultTimeout(TestConstants.LongTimeoutDuration); 164await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 165await app.StopAsync(token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 185using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 191var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 192var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 212await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 213var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 221var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 229await orchestrator.StopResourceAsync(notStartedResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 230await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 233await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 234await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 236await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 237await app.StopAsync(token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 275using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestTimeout); 285await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 288await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 291await resourcesCreatedTcs.Task.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 297await app.StopAsync(token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 319using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestTimeout); 328var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 334await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 337await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 339await startTask.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 344await app.StopAsync(token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 365await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 369await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 394using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 400var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 401var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 420await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 421var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 428var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 436await orchestrator.StopResourceAsync(notStartedResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 437await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 440await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 441await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 443await startTask.DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 444await app.StopAsync(token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 473using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.ExtraLongTimeoutDuration); 483notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 484dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 503await orchestrator.StartResourceAsync(notStartedResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 506var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 513var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 521await orchestrator.StopResourceAsync(runningResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 522await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 528await orchestrator.StartResourceAsync(runningResourceEvent.ResourceId, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 529await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 532await startTask.DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 533await app.StopAsync(token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 594await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 596var appModel = await tcs.Task.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 633await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 639await Task.WhenAll(clientA.GetStringAsync("/pid"), clientC.GetStringAsync("/pid")).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 686await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 689var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 699await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 743await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 746var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 764await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 787await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 790var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 809await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 861await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 865var list = await s.ListAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 935await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 960await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 962var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 964await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 993await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1000r => r.Spec.Env != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1010await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1033await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1040r => r.Spec.Env != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1049await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1075await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1077using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestLongTimeout); 1081var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1087await orchestrator.StopResourceAsync(redisContainer.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1089redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, containerPattern, r => r.Status?.State == ContainerState.Exited, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1100await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1115using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestLongTimeout); 1118await app.StartAsync(token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1121var serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1124await orchestrator.StopResourceAsync(serviceA.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1126serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Finished, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1129await orchestrator.StartResourceAsync(serviceA.Metadata.Name, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1131serviceA = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, executablePattern, r => r.Status?.State == ExecutableState.Running, token).DefaultTimeout(TestConstants.LongTimeoutDuration); 1134await app.StopAsync(token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1157await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1160var redisContainer = await KubernetesHelper.GetResourceByNameMatchAsync<Container>(kubernetes, $"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1163var serviceA = await KubernetesHelper.GetResourceByNameAsync<Executable>(kubernetes, $"{testName}-servicea", suffix!, r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1166var nodeApp = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"{testName}-nodeapp-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1183await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1206await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1217await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1238await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1241var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1251await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1275await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1278var aspireDashboard = await KubernetesHelper.GetResourceByNameMatchAsync<Executable>(kubernetes, $"aspire-dashboard-{ReplicaIdRegex}-{suffix}", r => r.Status?.EffectiveEnv is not null).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1284await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1305await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1311r => r.Status?.State == ContainerState.FailedToStart && (r.Status?.Message.Contains("bob") ?? false)).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1317await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1333await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1340$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1346await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1361await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1368$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1375await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1390await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1397$"{testName}-redis-{ReplicaIdRegex}-{suffix}", r => r.Spec.VolumeMounts != null).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1403await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1415await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1434await foreach (var resource in s.WatchAsync<Container>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1448await foreach (var resource in s.WatchAsync<Executable>().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout)) 1475var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1493var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1515await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1519var result = await client.GetStringAsync("pid").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1531}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1558await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1560using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 1564await app.WaitForTextAsync("Content root path:", resourceName: testProgram.ServiceABuilder.Resource.Name).DefaultTimeout(TestConstants.LongTimeoutDuration); 1629await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1632await app.WaitForTextAsync("Application started.").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1636await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1676await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1698await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1701await app.WaitForTextAsync("Application started.").DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1705await clientA.GetStringAsync("/").DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1750await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1767var ex = await Assert.ThrowsAsync<InvalidOperationException>(async () => await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout)); 1790await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1826await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1828await kubernetesLifecycle.HooksCompleted.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 1842using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestLongTimeout); 1845await app.StartAsync(token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1852.DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 1857using (var logCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestTimeout)) 1866using (var logCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestTimeout)) 1880using (var logCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.DefaultOrchestratorTestTimeout)) 1894await app.StopAsync(token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);

190await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 194await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 217await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 222await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 328await app.StartAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

49await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 225var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 242await app.StopAsync(abortTokenSource.Token).TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 266var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 309var abortTokenSource = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 358await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 424var pendingStart = app.StartAsync().DefaultTimeout(TestConstants.LongTimeoutDuration); 558await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 606await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan); 652await app.StopAsync().TimeoutAfter(TestConstants.LongTimeoutTimeSpan);

104await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 106await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 110await rns.WaitForResourceHealthyAsync(resource.Resource.Name).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 112await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 114await pendingStart.DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 116await app.StopAsync().DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 135}).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout);

32await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 34var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 36await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 61await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 63var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 65await app.StopAsync().WaitAsync(TestConstants.LongTimeoutTimeSpan); 90await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 92var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 94await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 121await app.StartAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 123var context = await tcs.Task.WaitAsync(TestConstants.DefaultTimeoutTimeSpan); 125await app.StopAsync().WaitAsync(TestConstants.DefaultTimeoutTimeSpan);

37using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 69using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 100using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 137using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 171using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 201using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 237using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 276using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 311using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 343using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 372using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 422using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 451using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 475using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 510using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 541using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 573using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 609using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 656using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 729using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 824using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 876using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 1216using var cts = new CancellationTokenSource(TestConstants.DefaultTimeoutTimeSpan); 1264using var cts = new CancellationTokenSource(TestConstants.DefaultTimeoutTimeSpan); 1297using var cts = new CancellationTokenSource(TestConstants.LongTimeoutTimeSpan); 1340using var cts = new CancellationTokenSource(TestConstants.DefaultTimeoutTimeSpan); 1373using var cts = new CancellationTokenSource(TestConstants.DefaultTimeoutTimeSpan);

27using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 52using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 71using var cts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration);

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

40milliseconds = TestConstants.DefaultTimeoutDuration; 55milliseconds = TestConstants.DefaultTimeoutDuration; 87milliseconds = TestConstants.DefaultTimeoutDuration; 102milliseconds = TestConstants.DefaultTimeoutDuration; 117milliseconds = TestConstants.DefaultTimeoutDuration; 132milliseconds = TestConstants.DefaultTimeoutDuration;

29var abortCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 104using var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 107using var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 135using var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 138using var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 168var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 174var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 212var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 215var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 323var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 326var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 357var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 360var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 404var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 407var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 446var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 452var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 468var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 493var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 499var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 515var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 548var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 554var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 571var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 602var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 608var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 623var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 653var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 659var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 706var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 712var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 755var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 761var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 870var startupCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 874var waitingStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration); 884var runningStateCts = AsyncTestHelpers.CreateDefaultTimeoutTokenSource(TestConstants.LongTimeoutDuration);

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