372 references to Running
Aspire.Hosting (20)
ApplicationModel\CommandsConfigurationExtensions.cs (1)
300&& priorState == KnownResourceStates.Running;
ApplicationModel\CustomResourceSnapshot.cs (1)
150if (state != KnownResourceStates.Running)
ApplicationModel\KnownResourceStates.cs (2)
25public static readonly string Running = nameof(Running); 85public static readonly IReadOnlyList<string> BuildableStates = [Running, Waiting, Finished, FailedToStart, Exited];
ApplicationModel\ResourceNotificationService.cs (7)
105string[] targetStates = !string.IsNullOrEmpty(targetState) ? [targetState] : [KnownResourceStates.Running]; 195/// it reaches a <see cref="KnownResourceStates.Running"/> state. 223/// it reaches a <see cref="KnownResourceStates.Running"/> state. The 229/// will continue to wait until the resource reaches a <see cref="KnownResourceStates.Running"/> state. 376resourceLogger.LogInformation("Waiting for resource '{ResourceName}' to enter the '{State}' state.", dependency.Name, KnownResourceStates.Running); 437WaitBehavior.WaitOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running, 438WaitBehavior.StopOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running ||
Backchannel\AuxiliaryBackchannelRpcTarget.cs (2)
712re => re.Snapshot.State?.Text == KnownResourceStates.Running || 720var isRunning = state == KnownResourceStates.Running;
ConnectionStringBuilderExtensions.cs (1)
99State = KnownResourceStates.Running
Dcp\ResourceSnapshotBuilder.cs (1)
340var resourceRunning = string.Equals(resourceState, KnownResourceStates.Running, StringComparisons.ResourceState);
ExternalServiceBuilderExtensions.cs (1)
176State = KnownResourceStates.Running
Health\ResourceHealthCheckService.cs (1)
42if (resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running)
Orchestrator\ParameterProcessor.cs (2)
164await UpdateParameterStateAsync(parameterResource, value, KnownResourceStates.Running).ConfigureAwait(false); 510await UpdateParameterStateAsync(parameterResource, inputValue, KnownResourceStates.Running).ConfigureAwait(false);
ResourceBuilderExtensions.cs (1)
3703var targetRunning = resourceState == KnownResourceStates.Running || resourceState == KnownResourceStates.RuntimeUnhealthy;
Aspire.Hosting.Azure (5)
AzureProvisioningController.cs (5)
1080: new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 2161environmentEvent.Snapshot.State?.Text != KnownResourceStates.Running) 3387return resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running; 3729State = new(KnownResourceStates.Running, KnownResourceStateStyles.Success) 4236_status = KnownResourceStates.Running;
Aspire.Hosting.Azure.Functions (1)
DurableTask\DurableTaskResourceExtensions.cs (1)
238State = KnownResourceStates.Running,
Aspire.Hosting.Azure.Kusto (2)
AzureKustoBuilderExtensions.cs (2)
365return context.ResourceSnapshot.State?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled; 376return context.ResourceSnapshot.State?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled;
Aspire.Hosting.Azure.Tests (81)
AzureCosmosDBEmulatorFunctionalTests.cs (2)
48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 56await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureEnvironmentResourceExtensionsTests.cs (63)
332State = KnownResourceStates.Running, 341State = KnownResourceStates.Running, 570Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 706await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 741await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 1666await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1704await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1724Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 1788await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 1830Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 1951await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 1952await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 1953await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2030await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2100State = KnownResourceStates.Running, 2107State = KnownResourceStates.Running, 2141Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 2173await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2174await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2201Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 2226await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2227await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2228await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2287await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2288await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2704await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2705await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2706await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2779await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2832await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2892await notifications.PublishUpdateAsync(visibleResource, state => state with { State = KnownResourceStates.Running }); 2947await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3022State = KnownResourceStates.Running, 3040Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 3082State = KnownResourceStates.Running, 3153await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3208State = KnownResourceStates.Running, 3271State = KnownResourceStates.Running, 3343State = KnownResourceStates.Running, 3398await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3399await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3485Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 3615State = KnownResourceStates.Running, 3758State = KnownResourceStates.Running, 3843await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4069await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 4121await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4167await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 4213await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4327await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4328await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4380await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4381await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4386Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 4389Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text); 4438await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4439await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4440await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 4448Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 4482await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4483await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4488Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 4491Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text);
AzureEventHubsExtensionsTests.cs (2)
48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureServiceBusExtensionsTests.cs (4)
98await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 106await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 139await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 848await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureSignalREmulatorFunctionalTest.cs (2)
60await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token); 67await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
AzureStorageEmulatorFunctionalTests.cs (6)
51await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 61await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 96await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 104await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 139await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 147await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
FoundryExtensionsTests.cs (2)
99await rns.WaitForResourceAsync(resource.Name, [KnownResourceStates.FailedToStart, KnownResourceStates.Running], cts.Token); 355.WaitForResourceAsync(deployment.Resource.Name, KnownResourceStates.Running, cancellation.Token)
Aspire.Hosting.Blazor (2)
BlazorGatewayExtensions.cs (1)
434var isRunning = gatewayState?.Text == KnownResourceStates.Running;
BrowserDebuggerHelper.cs (1)
221&& ctx.ResourceSnapshot.State?.Text == KnownResourceStates.Running
Aspire.Hosting.Blazor.Tests (2)
BlazorHostedExtensionsTests.cs (1)
554State = KnownResourceStates.Running
WithBlazorAppTests.cs (1)
297State = KnownResourceStates.Running
Aspire.Hosting.Browsers (5)
BrowserLogsBuilderExtensions.cs (2)
189if (parentState == KnownResourceStates.Running || parentState == KnownResourceStates.RuntimeUnhealthy) 279return childState == KnownResourceStates.Running
BrowserLogsSessionManager.cs (3)
128stateText: resourceState.ActiveSessions.Count > 0 ? KnownResourceStates.Running : KnownResourceStates.FailedToStart, 167stateText: KnownResourceStates.Running, 346? (KnownResourceStates.Running, KnownResourceStateStyles.Success)
Aspire.Hosting.Browsers.Tests (50)
BrowserLogsBuilderExtensionsTests.cs (45)
38State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 92State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 147State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 183State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 216State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 293State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 320State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 344State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 370State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 392State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 413State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 437State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 473State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 516State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 556State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 595State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 640State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 680State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 690State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 730State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 784State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 828State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 868State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 941State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 965resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 997State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1014resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1035resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1082State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1099resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1112resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1155State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1211State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1236resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1271State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1287resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1307State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1355State = KnownResourceStates.Running 1391State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1411resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1447resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1479resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1526State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1548resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1594State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success),
src\Aspire.Hosting.Browsers\BrowserLogsBuilderExtensions.cs (2)
189if (parentState == KnownResourceStates.Running || parentState == KnownResourceStates.RuntimeUnhealthy) 279return childState == KnownResourceStates.Running
src\Aspire.Hosting.Browsers\BrowserLogsSessionManager.cs (3)
128stateText: resourceState.ActiveSessions.Count > 0 ? KnownResourceStates.Running : KnownResourceStates.FailedToStart, 167stateText: KnownResourceStates.Running, 346? (KnownResourceStates.Running, KnownResourceStateStyles.Success)
Aspire.Hosting.DevTunnels (2)
DevTunnelResourceBuilderExtensions.cs (2)
656context.ResourceSnapshot.State?.Text == KnownResourceStates.Running && 763State = KnownResourceStates.Running,
Aspire.Hosting.DevTunnels.Tests (3)
DevTunnelResourceBuilderExtensionsTests.cs (3)
538State = KnownResourceStates.Running 559State = KnownResourceStates.Running 727e => e.Snapshot.State?.Text == KnownResourceStates.Running &&
Aspire.Hosting.DotnetTool.Tests (2)
DotnetToolFunctionalTests.cs.cs (2)
23await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.EntityFrameworkCore (2)
EFResourceBuilderExtensions.cs (2)
497State = KnownResourceStates.Running 853await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Running, KnownResourceStateStyles.Info).ConfigureAwait(false);
Aspire.Hosting.EntityFrameworkCore.Tests (2)
EFMigrationCommandsTests.cs (2)
232State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Info) 262State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Info)
Aspire.Hosting.Foundry (7)
FoundryExtensions.cs (2)
371State = KnownResourceStates.Running, 449State = KnownResourceStates.Running,
PromptAgent\AzurePromptAgentResource.cs (1)
397KnownResourceStates.Running,
Toolbox\FoundryToolboxResource.cs (4)
382State = new(KnownResourceStates.Running, KnownResourceStateStyles.Success), 463KnownResourceStates.Running, 495[KnownResourceStates.Running, .. KnownResourceStates.TerminalStates], 497if (!StringComparers.ResourceState.Equals(state, KnownResourceStates.Running))
Aspire.Hosting.Garnet.Tests (2)
GarnetFunctionalTests.cs (2)
42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.GitHub.Models (1)
GitHubModelsExtensions.cs (1)
75State = KnownResourceStates.Running,
Aspire.Hosting.GitHub.Models.Tests (2)
GitHubModelsFunctionalTests.cs (2)
41await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.JavaScript.Tests (1)
DenoAppFixture.cs (1)
162KnownResourceStates.Running,
Aspire.Hosting.Kafka.Tests (2)
KafkaFunctionalTests.cs (2)
44await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 52await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Maui (1)
Lifecycle\MauiBuildQueueEventSubscriber.cs (1)
470return (releaseOnRunning && string.Equals(state, KnownResourceStates.Running, StringComparisons.ResourceState))
Aspire.Hosting.Maui.Tests (6)
MauiBuildQueueTests.cs (3)
604Assert.Equal(ResourceCommandState.Enabled, stopCommand.UpdateState(CreateUpdateStateContext(env, KnownResourceStates.Running))); 670State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 737State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success)
MauiPlatformExtensionsTests.cs (3)
925State = KnownResourceStates.Running, 1222State = KnownResourceStates.Running 1333State = KnownResourceStates.Running
Aspire.Hosting.MongoDB (2)
ReplicaSet\MongoDBReplicaSetBuilderExtensions.cs (2)
369State = KnownResourceStates.Running, 538? s with { State = KnownResourceStates.Running }
Aspire.Hosting.MongoDB.Tests (5)
MongoDbFunctionalTests.cs (3)
56await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 64await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 135await app.ResourceNotifications.WaitForResourceAsync(mongoExpress.Resource.Name, KnownResourceStates.Running, cts.Token);
ReplicaSet\AddMongoDBReplicaSetTests.cs (2)
313State = KnownResourceStates.Running 339Assert.Equal(KnownResourceStates.Running, GetReplicaSetState());
Aspire.Hosting.MySql.Tests (2)
MySqlFunctionalTests.cs (2)
51await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 59await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Nats.Tests (2)
NatsFunctionalTests.cs (2)
349await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 357await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.OpenAI (2)
OpenAIExtensions.cs (2)
86State = KnownResourceStates.Running, 132State = KnownResourceStates.Running,
Aspire.Hosting.OpenAI.Tests (4)
OpenAIFunctionalTests.cs (4)
43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 90await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 98await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Oracle.Tests (2)
OracleFunctionalTests.cs (2)
467await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 475await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.PostgreSQL.Tests (2)
PostgresFunctionalTests.cs (2)
54await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 66await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Qdrant.Tests (2)
QdrantFunctionalTests.cs (2)
278await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 286await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.RabbitMQ.Tests (2)
RabbitMQFunctionalTests.cs (2)
43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);
Aspire.Hosting.Redis.Tests (8)
RedisFunctionalTests.cs (8)
53await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 122e => e.Snapshot.State == KnownResourceStates.Running, 168e => e.Snapshot.State == KnownResourceStates.Running, 180e => e.Snapshot.State == KnownResourceStates.Running, 296await rns.WaitForResourceAsync(redisInsightBuilder.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 631await rns.WaitForResourceAsync(redisInsightBuilder1.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token); 666await rns.WaitForResourceAsync(redisInsightBuilder2.Resource.Name, KnownResourceStates.Running).WaitAsync(cts.Token);
Aspire.Hosting.SqlServer.Tests (2)
SqlServerFunctionalTests.cs (2)
46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Hosting.Testing.Tests (1)
DashboardUrlTests.cs (1)
107resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running,
Aspire.Hosting.Tests (129)
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (3)
1440State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 1479State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 2171State = KnownResourceStates.Running,
Codespaces\CodespacesUrlRewriterTests.cs (1)
75State = KnownResourceStates.Running,
ContainerTunnelTests.cs (2)
114await app.ResourceNotifications.WaitForResourceAsync(c.Resource.Name, KnownResourceStates.Running) 148await app.ResourceNotifications.WaitForResourceAsync(resourceName, KnownResourceStates.Running)
DistributedApplicationTests.cs (16)
213await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 225await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 277var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 285var dependentResourceRunningEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 302await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 353await rns.WaitForResourceAsync(normalResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 405await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 577var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 584var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 597await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 662var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 669var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 685await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 1110var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 2163e => e.Snapshot.State?.Text == KnownResourceStates.Running && 2168e => e.Snapshot.State?.Text == KnownResourceStates.Running &&
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
359await app.ResourceNotifications.WaitForResourceAsync("redis", KnownResourceStates.Running).DefaultTimeout();
ExternalServiceTests.cs (2)
396e => e.Snapshot.State?.Text == KnownResourceStates.Running 400Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text);
Health\ResourceHealthCheckServiceTests.cs (21)
43State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 83State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 126State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 130e => e.Snapshot.State?.Text == KnownResourceStates.Running && e.Snapshot.HealthReports.Single().Status == HealthStatus.Unhealthy).DefaultTimeout(); 165State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 188State = new ResourceStateSnapshot(KnownResourceStates.Running, null), 231State = KnownResourceStates.Running 272State = KnownResourceStates.Running 315State = KnownResourceStates.Running 317await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, abortTokenSource.Token).DefaultTimeout(); 351State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 382State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 444State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 489State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 540State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 548State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 592State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 596var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 638State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 641var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();
HealthCheckTests.cs (2)
137await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 145await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);
Orchestrator\ApplicationOrchestratorTests.cs (16)
607await resourceNotificationService.WaitForResourceAsync(blocker.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 608await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 644Assert.NotEqual(KnownResourceStates.Running, dependencyEvent.Snapshot.State?.Text); 648await resourceNotificationService.WaitForResourceAsync(dependency.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 684State = KnownResourceStates.Running 914await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 917Assert.NotEqual(KnownResourceStates.Running, blockerEvent.Snapshot.State?.Text); 980await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, cancellationToken).DefaultTimeout(); 983Assert.NotEqual(KnownResourceStates.Running, blockerEvent.Snapshot.State?.Text); 1017await resourceNotificationService.WaitForResourceAsync(referenced.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1018await resourceNotificationService.WaitForResourceAsync(connectionString.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1060await resourceNotificationService.WaitForResourceAsync(blocker.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1061await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1107State = KnownResourceStates.Running, 1325Assert.NotEqual(KnownResourceStates.Running, childContainerState); 1372Assert.NotEqual(KnownResourceStates.Running, childProjectState);
Orchestrator\ParameterProcessorTests.cs (4)
105Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 263Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 267Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 271Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text);
ResourceNotificationTests.cs (27)
154(snapshot with { State = KnownResourceStates.Running }).WithHealthReports( 287await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = KnownResourceStates.Running }).DefaultTimeout(); 381State = KnownResourceStates.Running 394State = KnownResourceStates.Running 430State = KnownResourceStates.Running, 448State = KnownResourceStates.Running, 539State = KnownResourceStates.Running 546[InlineData(nameof(KnownResourceStates.Running))] 571State = KnownResourceStates.Running 619State = KnownResourceStates.Running 649State = KnownResourceStates.Running 689State = KnownResourceStates.Running 728State = KnownResourceStates.Running 761State = KnownResourceStates.Running 774State = KnownResourceStates.Running 800State = KnownResourceStates.Running 816State = KnownResourceStates.Running 826var waitTask = notificationService.WaitForResourceAsync(resource.Name, KnownResourceStates.Running, cts.Token); 1183Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1201Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1248Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1257Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1280State = KnownResourceStates.Running 1286State = KnownResourceStates.Running, 1325State = KnownResourceStates.Running, 1350State = KnownResourceStates.Running 1358State = KnownResourceStates.Running,
WaitForTests.cs (16)
112State = KnownResourceStates.Running 143State = KnownResourceStates.Running 183State = KnownResourceStates.Running 374State = KnownResourceStates.Running 377await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 421State = KnownResourceStates.Running 424await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 469await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token); 563State = KnownResourceStates.Running 666State = KnownResourceStates.Running, 674State = KnownResourceStates.Running, 677await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 730await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 771await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 880State = KnownResourceStates.Running 885await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token);
WithHttpCommandTests.cs (9)
629State = KnownResourceStates.Running 631await app.ResourceNotifications.WaitForResourceAsync(serviceA.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 964State = KnownResourceStates.Running 970e => e.Snapshot.State?.Text == KnownResourceStates.Running && 1007State = KnownResourceStates.Running 1013e => e.Snapshot.State?.Text == KnownResourceStates.Running && 1022State = KnownResourceStates.Running 1061State = KnownResourceStates.Running 1069e => e.Snapshot.State?.Text == KnownResourceStates.Running &&
WithUrlsTests.cs (9)
448e => e.Snapshot.State == KnownResourceStates.Running 487if (notification.Snapshot.State == KnownResourceStates.Running && 497await rns.WaitForResourceAsync(servicea.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 581State = KnownResourceStates.Running 603if (notification.Snapshot.State == KnownResourceStates.Running && 613await rns.WaitForResourceAsync(custom.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 674e => e.Snapshot.State == KnownResourceStates.Running && e.Snapshot.Urls.Length == 4).DefaultTimeout(); 975e => e.Snapshot.State == KnownResourceStates.Running 1027e => e.Snapshot.State == KnownResourceStates.Running,
Aspire.Hosting.Valkey.Tests (2)
ValkeyFunctionalTests.cs (2)
227await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 235await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);
Aspire.Playground.Tests (3)
Infrastructure\DistributedApplicationExtensions.cs (3)
88targetState ??= KnownResourceStates.Running; 97/// If <paramref name="targetStates"/> is null, the default states are <see cref="KnownResourceStates.Running"/> and <see cref="KnownResourceStates.Hidden"/>. 102targetStates ??= [KnownResourceStates.Running, KnownResourceStates.Hidden];
CustomResources.AppHost (1)
TalkingClockResource.cs (1)
79State = KnownResourceStates.Running // Use an Aspire well-known state.