36State = KnownResourceStates.Active

136static bool IsStopped(string? state) => KnownResourceStates.TerminalStates.Contains(state) || state == KnownResourceStates.NotStarted || state == "Unknown"; 137static bool IsStopping(string? state) => state == KnownResourceStates.Stopping; 138static bool IsStarting(string? state) => state == KnownResourceStates.Starting; 139static bool IsWaiting(string? state) => state == KnownResourceStates.Waiting; 140static bool IsBuilding(string? state) => state == KnownResourceStates.Building; 141static bool IsRuntimeUnhealthy(string? state) => state == KnownResourceStates.RuntimeUnhealthy; 167return state is not null && KnownResourceStates.BuildableStates.Contains(state) 227|| state != KnownResourceStates.Waiting); 236s.State?.Text == KnownResourceStates.Waiting 238: s with { State = new ResourceStateSnapshot(KnownResourceStates.Building, KnownResourceStateStyles.Info) } 277if (terminalEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart) 283State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 297State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 312&& priorState == KnownResourceStates.Running; 315&& waitState == KnownResourceStates.Waiting; 330State = new ResourceStateSnapshot(KnownResourceStates.Starting, KnownResourceStateStyles.Info) 363State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 375State = new ResourceStateSnapshot(KnownResourceStates.Finished, KnownResourceStateStyles.Info) 392(state == KnownResourceStates.FailedToStart || 393(KnownResourceStates.TerminalStates.Contains(state) && resourceEvent.Snapshot.ExitCode is not null));

150if (state != KnownResourceStates.Running) 319/// <param name="Text">The text for the state update. See <see cref="KnownResourceStates"/> for expected values.</param>

89/// Waits for a resource to reach the specified state. See <see cref="KnownResourceStates"/> for common states. 98/// <param name="targetState">The state to wait for the resource to transition to. See <see cref="KnownResourceStates"/> for common states.</param> 105string[] targetStates = !string.IsNullOrEmpty(targetState) ? [targetState] : [KnownResourceStates.Running]; 110/// Waits for a resource to reach one of the specified states. See <see cref="KnownResourceStates"/> for common states. 119/// <param name="targetStates">The set of states to wait for the resource to transition to one of. See <see cref="KnownResourceStates"/> for common states.</param> 200/// it reaches a <see cref="KnownResourceStates.Running"/> state. 203/// If the resource enters an unavailable state such as <see cref="KnownResourceStates.FailedToStart"/> then 228/// it reaches a <see cref="KnownResourceStates.Running"/> state. The 230/// enters an unavailable state such as <see cref="KnownResourceStates.FailedToStart"/>. 234/// will continue to wait until the resource reaches a <see cref="KnownResourceStates.Running"/> state. 320snapshot.State?.Text == KnownResourceStates.Finished || 321snapshot.State?.Text == KnownResourceStates.Exited || 322snapshot.State?.Text == KnownResourceStates.FailedToStart || 323snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 364if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 373else if ((snapshot.State!.Text == KnownResourceStates.Finished || snapshot.State!.Text == KnownResourceStates.Exited) && snapshot.ExitCode is not null && snapshot.ExitCode != exitCode) 396KnownResourceStates.TerminalStates.Contains(snapshot.State?.Text) || 405resourceLogger.LogInformation("Waiting for resource '{ResourceName}' to enter the '{State}' state.", dependency.Name, KnownResourceStates.Running); 430if (snapshot.State?.Text == KnownResourceStates.FailedToStart) 439else if (snapshot.State!.Text == KnownResourceStates.Finished || 440snapshot.State.Text == KnownResourceStates.Exited || 441snapshot.State.Text == KnownResourceStates.RuntimeUnhealthy) 466WaitBehavior.WaitOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running, 467WaitBehavior.StopOnResourceUnavailable => snapshot.State?.Text == KnownResourceStates.Running || 468snapshot.State?.Text == KnownResourceStates.Finished || 469snapshot.State?.Text == KnownResourceStates.Exited || 470snapshot.State?.Text == KnownResourceStates.FailedToStart || 471snapshot.State?.Text == KnownResourceStates.RuntimeUnhealthy, 643State = KnownResourceStates.Waiting, 651|| (allowNotStarted && state == KnownResourceStates.NotStarted) 652|| state == KnownResourceStates.Starting 653|| state == KnownResourceStates.Waiting; 879if (!string.Equals(newState.State?.Text, KnownResourceStates.Waiting, StringComparisons.ResourceState)) 1254state == KnownResourceStates.Finished || state == KnownResourceStates.Exited;

734re => re.Snapshot.State?.Text == KnownResourceStates.Running || 735KnownResourceStates.TerminalStates.Contains(re.Snapshot.State?.Text, StringComparers.ResourceState) || 742var isRunning = state == KnownResourceStates.Running; 758re => KnownResourceStates.TerminalStates.Contains(re.Snapshot.State?.Text) || re.Snapshot.ExitCode is not null,

84State = KnownResourceStates.NotStarted, 98State = KnownResourceStates.Running 112State = KnownResourceStates.FailedToStart

1002new ResourceStatus(KnownResourceStates.NotStarted, null, null), 1006State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null) 1023new ResourceStatus(KnownResourceStates.NotStarted, null, null), 1027State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, null)

371var isTerminal = status.State is not null && KnownResourceStates.TerminalStates.Contains(status.State); 483var follow = status.State != KnownResourceStates.FailedToStart; 560return new(KnownResourceStates.NotStarted, null, null); 570return new(KnownResourceStates.NotStarted, null, null);

36state = KnownResourceStates.NotStarted; 159state = KnownResourceStates.NotStarted; 597var resourceRunning = string.Equals(resourceState, KnownResourceStates.Running, StringComparisons.ResourceState);

857if (KnownResourceStates.TerminalStates.Contains(Snapshot?.State?.Text, StringComparers.ResourceState))

109State = KnownResourceStates.Waiting, 147State = KnownResourceStates.FailedToStart 159State = KnownResourceStates.FailedToStart 176State = KnownResourceStates.Running

42if (resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running) 73else if (KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text)) 85&& KnownResourceStates.TerminalStates.Contains(evt.Snapshot.State?.Text));

45KnownResourceStates.FailedToStart, 46KnownResourceStates.Finished, 47KnownResourceStates.Exited, 74if (state != KnownResourceStates.FailedToStart

162if (e.Snapshot.State?.Text == KnownResourceStates.Waiting) 245State = KnownResourceStates.Starting, 258State = KnownResourceStates.Starting, 270await SetChildResourceAsync(context.Resource, state: KnownResourceStates.Starting, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false); 591KnownResourceStates.TerminalStates.Contains(state) && 592!KnownResourceStates.TerminalStates.Contains(context.PreviousState)) 606? new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 607: new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null); 615await SetChildResourceAsync(context.Resource, KnownResourceStates.FailedToStart, startTimeStamp: null, stopTimeStamp: null).ConfigureAwait(false); 656if (s.State?.Text == KnownResourceStates.Waiting) 659return s with { State = KnownResourceStates.Starting };

240await UpdateParameterStateAsync(parameterResource, ex.Message, new(KnownResourceStates.ValueMissing, KnownResourceStateStyles.Warn)).ConfigureAwait(false); 281await UpdateParameterStateAsync(parameterResource, eventArgs.Value, KnownResourceStates.Running).ConfigureAwait(false); 292await UpdateParameterStateAsync(parameterResource, eventArgs.Exception.Message, new(KnownResourceStates.ValueMissing, KnownResourceStateStyles.Warn)).ConfigureAwait(false);

337State = KnownResourceStates.Waiting

1171State = KnownResourceStates.NotStarted,

4074var targetRunning = resourceState == KnownResourceStates.Running || resourceState == KnownResourceStates.RuntimeUnhealthy;

354State = KnownResourceStates.NotStarted,

45State = KnownResourceStates.NotStarted,

1125: new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1246State = KnownResourceStates.NotStarted, 1779await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 1829await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 1839await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 1855await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 1889await PublishAzureEnvironmentStateAsync(model, KnownResourceStates.NotStarted, cancellationToken).ConfigureAwait(false); 2257environmentEvent.Snapshot.State?.Text != KnownResourceStates.Running) 3513return resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running; 3860State = new(KnownResourceStates.Running, KnownResourceStateStyles.Success) 4269new ResourceStateSnapshot(state, state == KnownResourceStates.NotStarted ? KnownResourceStateStyles.Info : KnownResourceStateStyles.Success), 4296var azureEnvironmentProperties = state.Text == KnownResourceStates.NotStarted 4310Properties = state.Text == KnownResourceStates.NotStarted 4313Urls = state.Text == KnownResourceStates.NotStarted ? [] : existingState.Urls, 4314CreationTimeStamp = state.Text == KnownResourceStates.NotStarted ? null : existingState.CreationTimeStamp, 4315StartTimeStamp = state.Text == KnownResourceStates.NotStarted ? null : existingState.StartTimeStamp, 4316StopTimeStamp = state.Text == KnownResourceStates.NotStarted ? null : existingState.StopTimeStamp 4319if (state.Text == KnownResourceStates.NotStarted) 4367_status = KnownResourceStates.Running;

86State = KnownResourceStates.Waiting, 260State = KnownResourceStates.Running 315State = KnownResourceStates.FailedToStart

27Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 59Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 80Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 112Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 133Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 152Assert.Equal(KnownResourceStates.FailedToStart, snapshot.State?.Text); 172Assert.Equal(KnownResourceStates.FailedToStart, snapshot.State?.Text); 190Assert.Equal(KnownResourceStates.FailedToStart, snapshot.State?.Text); 210Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 229Assert.Equal(KnownResourceStates.FailedToStart, snapshot.State?.Text); 281update => update.Snapshot.State?.Text == KnownResourceStates.FailedToStart, cts.Token); 283await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with { State = KnownResourceStates.Waiting }); 287await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with { State = KnownResourceStates.Running }); 294Assert.Equal(KnownResourceStates.Running, ready.Snapshot.State?.Text); 332await notifications.PublishUpdateAsync(entra.Resource, snapshot => snapshot with { State = KnownResourceStates.Waiting }); 337update => update.Snapshot.State?.Text == KnownResourceStates.Running && 416Assert.Equal(KnownResourceStates.FailedToStart, snapshot.State?.Text); 445Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 467Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 481Assert.Equal(KnownResourceStates.FailedToStart, snapshot.State?.Text); 504update => update.Snapshot.State?.Text == KnownResourceStates.FailedToStart ||

294Assert.Equal(KnownResourceStates.Waiting, annotation.InitialSnapshot.State?.Text);

242State = KnownResourceStates.Running,

316State = KnownResourceStates.FailedToStart 365return context.ResourceSnapshot.State?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled; 376return context.ResourceSnapshot.State?.Text == KnownResourceStates.Running ? ResourceCommandState.Enabled : ResourceCommandState.Disabled;

221await rns.WaitForResourceAsync(db2.Resource.Name, KnownResourceStates.FailedToStart, cts.Token);

48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 56await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

101State = KnownResourceStates.Running, 121Assert.Equal(KnownResourceStates.Running, directorySnapshot.Snapshot.State?.Text); 628State = KnownResourceStates.Running, 637State = KnownResourceStates.Running, 677Assert.Equal(KnownResourceStates.NotStarted, environmentEvent.Snapshot.State?.Text); 681Assert.Equal(KnownResourceStates.NotStarted, storageEvent.Snapshot.State?.Text); 866Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 1024await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 1059await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 1984await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2022await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2042Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 2106await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2145Assert.Equal(KnownResourceStates.NotStarted, storageEvent.Snapshot.State?.Text); 2148Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 2227Assert.Equal(KnownResourceStates.NotStarted, keyVaultEvent.Snapshot.State?.Text); 2269await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2270await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2271await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2348await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2418State = KnownResourceStates.Running, 2425State = KnownResourceStates.Running, 2454Assert.Equal(KnownResourceStates.NotStarted, storageEvent.Snapshot.State?.Text); 2459Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 2491await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2492await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2519Assert.Equal(KnownResourceStates.Running, storage2Event.Snapshot.State?.Text); 2544await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2545await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 2546await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 2605await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 2606await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3022await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 3023await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3024await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3097await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3150await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3210await notifications.PublishUpdateAsync(visibleResource, state => state with { State = KnownResourceStates.Running }); 3265await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3340State = KnownResourceStates.Running, 3358Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 3400State = KnownResourceStates.Running, 3471await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3526State = KnownResourceStates.Running, 3589State = KnownResourceStates.Running, 3661State = KnownResourceStates.Running, 3716await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 3717await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 3803Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 3933State = KnownResourceStates.Running, 4076State = KnownResourceStates.Running, 4161await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4387await notifications.PublishUpdateAsync(postgres.Resource, state => state with { State = KnownResourceStates.Running }); 4439await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4485await notifications.PublishUpdateAsync(keyVault.Resource, state => state with { State = KnownResourceStates.Running }); 4531await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4645await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4646await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4698await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4699await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4704Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 4707Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text); 4756await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4757await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4758await notifications.PublishUpdateAsync(storage2.Resource, state => state with { State = KnownResourceStates.Running }); 4766Assert.Equal(KnownResourceStates.Running, storageEvent.Snapshot.State?.Text); 4800await notifications.PublishUpdateAsync(environmentResource, state => state with { State = KnownResourceStates.Running }); 4801await notifications.PublishUpdateAsync(storage.Resource, state => state with { State = KnownResourceStates.Running }); 4806Assert.Equal(KnownResourceStates.Running, environmentEvent.Snapshot.State?.Text); 4809Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text);

48await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 49await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

99await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 101await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 107await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 140await rns.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token); 1179await app.ResourceNotifications.WaitForResourceAsync(serviceBus.Resource.Name, KnownResourceStates.Running, cts.Token);

60await app.ResourceNotifications.WaitForResourceAsync(signalR.Resource.Name, KnownResourceStates.Running, cts.Token); 61await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 67await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

51await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 53await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 61await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 96await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 98await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 104await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 139await rns.WaitForResourceAsync(storage.Resource.Name, KnownResourceStates.Running, cts.Token); 141await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 147await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

100await rns.WaitForResourceAsync(resource.Name, [KnownResourceStates.FailedToStart, KnownResourceStates.Running], cts.Token); 360.WaitForResourceAsync(deployment.Resource.Name, KnownResourceStates.Running, cancellation.Token)

198State = KnownResourceStates.Waiting, 222State = KnownResourceStates.Waiting, 522var isRunning = gatewayState?.Text == KnownResourceStates.Running;

221&& ctx.ResourceSnapshot.State?.Text == KnownResourceStates.Running 313var isTerminal = state == KnownResourceStates.Exited 314|| state == KnownResourceStates.Finished 315|| state == KnownResourceStates.FailedToStart 317|| state == KnownResourceStates.NotStarted;

197await app.ResourceNotifications.WaitForResourceAsync("client-publish", KnownResourceStates.Running, timeout.Token);

35Assert.Equal(KnownResourceStates.Waiting, state.State);

608State = KnownResourceStates.Running

29snapshot => snapshot with { State = KnownResourceStates.Starting }).DefaultTimeout(); 61snapshot => snapshot with { State = KnownResourceStates.Starting }).DefaultTimeout(); 75snapshot => snapshot with { State = KnownResourceStates.NotStarted }).DefaultTimeout();

298State = KnownResourceStates.Running

148State = KnownResourceStates.NotStarted, 180if (childState == KnownResourceStates.Starting) 189if (parentState == KnownResourceStates.Running || parentState == KnownResourceStates.RuntimeUnhealthy) 279return childState == KnownResourceStates.Running

101stateText: KnownResourceStates.Starting, 127stateText: resourceState.ActiveSessions.Count > 0 ? KnownResourceStates.Running : KnownResourceStates.FailedToStart, 166stateText: KnownResourceStates.Running, 345? (KnownResourceStates.Running, KnownResourceStateStyles.Success) 348not null => (KnownResourceStates.Exited, KnownResourceStateStyles.Error), 349null when exitCode is null or 0 => (KnownResourceStates.Finished, KnownResourceStateStyles.Success), 350_ => (KnownResourceStates.Exited, KnownResourceStateStyles.Error)

37State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 91State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 146State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 182State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 215State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 292State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 319State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 343State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 369State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 391State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 412State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 436State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 472State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 515State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 555State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 594State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 639State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 679State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 689State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 729State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 783State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 827State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 867State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 940State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 964resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 996State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1013resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1034resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1081State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1098resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1111resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1154State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1173resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart && 1210State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1226resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart && 1235resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1270State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1286resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1306State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1334State = KnownResourceStates.NotStarted, 1354State = KnownResourceStates.Running 1390State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1410resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1446resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1478resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1494resourceEvent.Snapshot.State?.Text == KnownResourceStates.Finished && 1500Assert.Equal(KnownResourceStates.Finished, allCompletedEvent.Snapshot.State?.Text); 1525State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success), 1547resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running && 1563resourceEvent.Snapshot.State?.Text == KnownResourceStates.Exited && 1593State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success),

148State = KnownResourceStates.NotStarted, 180if (childState == KnownResourceStates.Starting) 189if (parentState == KnownResourceStates.Running || parentState == KnownResourceStates.RuntimeUnhealthy) 279return childState == KnownResourceStates.Running

101stateText: KnownResourceStates.Starting, 127stateText: resourceState.ActiveSessions.Count > 0 ? KnownResourceStates.Running : KnownResourceStates.FailedToStart, 166stateText: KnownResourceStates.Running, 345? (KnownResourceStates.Running, KnownResourceStateStyles.Success) 348not null => (KnownResourceStates.Exited, KnownResourceStateStyles.Error), 349null when exitCode is null or 0 => (KnownResourceStates.Finished, KnownResourceStateStyles.Success), 350_ => (KnownResourceStates.Exited, KnownResourceStateStyles.Error)

43e => KnownResourceStates.TerminalStates.Contains(e.Snapshot.State?.Text), 46Assert.Equal(KnownResourceStates.Exited, state.Snapshot.State);

34await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 58await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 82await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 105await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, [KnownResourceStates.Exited, KnownResourceStates.FailedToStart], cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);

437&& KnownResourceStates.TerminalStates.Contains(update.Snapshot.State?.Text)) 702|| !KnownResourceStates.TerminalStates.Contains(current.Snapshot.State?.Text));

109State = KnownResourceStates.NotStarted, 201State = KnownResourceStates.Starting 649context.ResourceSnapshot.State?.Text == KnownResourceStates.Running && 704State = KnownResourceStates.NotStarted, 741&& previous.Snapshot.State?.Text == KnownResourceStates.Running 746State = KnownResourceStates.Running, 747StartTimeStamp = snapshot.State?.Text == KnownResourceStates.Running ? snapshot.StartTimeStamp : DateTime.UtcNow, 824&& KnownResourceStates.TerminalStates.Contains(current.Snapshot.State?.Text)) 834State = KnownResourceStates.Finished,

23Assert.Equal(KnownResourceStates.Running, test.Snapshot(test.Port).State?.Text); 66Assert.Equal(KnownResourceStates.NotStarted, test.Snapshot(test.Port).State?.Text); 155await test.App.ResourceNotifications.WaitForResourceAsync(test.Port.Name, KnownResourceStates.Running).DefaultTimeout(); 441Assert.Equal(KnownResourceStates.Finished, test.Snapshot(test.Port).State?.Text); 469Assert.Equal(KnownResourceStates.Finished, test.Snapshot(test.Port).State?.Text); 479await test.App.ResourceNotifications.PublishUpdateAsync(test.Tunnel, s => s with { State = KnownResourceStates.FailedToStart }); 480await test.App.ResourceNotifications.WaitForResourceAsync(test.Port.Name, KnownResourceStates.Finished).DefaultTimeout(); 553Assert.Equal(KnownResourceStates.Finished, test.Snapshot(test.Port).State?.Text); 707Assert.Equal(KnownResourceStates.Finished, test.Snapshot(test.Port).State?.Text);

582State = KnownResourceStates.Running 592State = KnownResourceStates.Finished 603State = KnownResourceStates.Running 811await app.ResourceNotifications.WaitForResourceAsync(tunnelPort.Name, KnownResourceStates.Finished, cts.Token); 824Assert.Equal(restartBeforeUrlCallbackCompletes ? KnownResourceStates.Running : KnownResourceStates.Finished, completed.Snapshot.State?.Text); 844e => e.Snapshot.State?.Text == KnownResourceStates.Running && 887await app.ResourceNotifications.WaitForResourceAsync(port.Name, KnownResourceStates.Running).DefaultTimeout();

60await App.ResourceNotifications.PublishUpdateAsync(Tunnel, s => s with { State = KnownResourceStates.Running }); 88e => e.Snapshot.State?.Text == KnownResourceStates.Running && e.Snapshot.HealthStatus == Microsoft.Extensions.Diagnostics.HealthChecks.HealthStatus.Healthy).DefaultTimeout();

192if (buildEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart || 202snapshot.State?.Text == KnownResourceStates.FailedToStart || 203(KnownResourceStates.TerminalStates.Contains(snapshot.State?.Text) && 306(state == KnownResourceStates.Starting || 307state == KnownResourceStates.Running || 308state == KnownResourceStates.Waiting || 309state == KnownResourceStates.Building || 310state == KnownResourceStates.Stopping || 311KnownResourceStates.TerminalStates.Contains(state))) 1262(resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart || 1263KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text)),

229State = KnownResourceStates.Finished, 246State = KnownResourceStates.Finished, 445State = KnownResourceStates.Finished, 589resourceEvent.Snapshot.State?.Text == KnownResourceStates.Finished && 595resourceEvent.Snapshot.State?.Text == KnownResourceStates.Finished && 1438State = KnownResourceStates.Finished, 1697State = KnownResourceStates.Finished, 1797State = KnownResourceStates.Finished, 1812State = KnownResourceStates.Finished, 1927State = KnownResourceStates.Finished, 2056State = KnownResourceStates.Finished, 2098State = KnownResourceStates.Finished, 2698[InlineData(nameof(KnownResourceStates.Finished), null, false)] 2699[InlineData(nameof(KnownResourceStates.Finished), -1, true)] 2700[InlineData(nameof(KnownResourceStates.Finished), 0, true)] 2701[InlineData(nameof(KnownResourceStates.Finished), 1, true)] 2702[InlineData(nameof(KnownResourceStates.FailedToStart), null, true)] 2764app.ResourceNotifications.WaitForResourceAsync("api", KnownResourceStates.Finished, completionCts.Token), 2765app.ResourceNotifications.WaitForResourceAsync("worker", KnownResourceStates.Finished, completionCts.Token)); 2824resourceEvent => resourceEvent.ResourceId == name && resourceEvent.Snapshot.State?.Text == KnownResourceStates.Finished, 2880resourceEvent => resourceEvent.ResourceId == name && resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart, 2930app.ResourceNotifications.WaitForResourceAsync("first", KnownResourceStates.Finished, completionCts.Token), 2931app.ResourceNotifications.WaitForResourceAsync("second", KnownResourceStates.Finished, completionCts.Token)); 2984KnownResourceStates.FailedToStart, 2987Assert.Equal(KnownResourceStates.Finished, firstBuildEvent.Snapshot.State?.Text); 2989Assert.Equal(KnownResourceStates.FailedToStart, secondBuildEvent.Snapshot.State?.Text); 3034app.ResourceNotifications.WaitForResourceAsync("valid", KnownResourceStates.Finished, completionCts.Token), 3035app.ResourceNotifications.WaitForResourceAsync("missing", KnownResourceStates.FailedToStart, completionCts.Token)); 3268Assert.Equal(KnownResourceStates.NotStarted, projectEvent.Snapshot.State?.Text); 3297State = KnownResourceStates.Finished, 3302State = KnownResourceStates.Finished, 3380[InlineData(nameof(KnownResourceStates.Finished), 1)] 3381[InlineData(nameof(KnownResourceStates.FailedToStart), null)] 3395State = KnownResourceStates.Finished, 3410State = KnownResourceStates.Running, 3417State = KnownResourceStates.Finished, 3453State = KnownResourceStates.Finished, 3475State = KnownResourceStates.Finished, 3480State = KnownResourceStates.NotStarted 3488State = KnownResourceStates.Running, 3495State = KnownResourceStates.Exited, 3537State = KnownResourceStates.Finished, 3572State = KnownResourceStates.Finished, 3598State = KnownResourceStates.Finished, 3631KnownResourceStates.FailedToStart, 3686KnownResourceStates.TerminalStates.Contains(resourceEvent.Snapshot.State?.Text) && 3691[KnownResourceStates.FailedToStart, KnownResourceStates.Exited, KnownResourceStates.Finished], 3695Assert.Equal(KnownResourceStates.FailedToStart, workerState); 3741resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.Starting, 3754snapshot => snapshot with { State = KnownResourceStates.Waiting }); 3762resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.Starting, 3785Assert.Equal(KnownResourceStates.Finished, buildEvent.Snapshot.State?.Text); 3793resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.FailedToStart, 3795Assert.Equal(KnownResourceStates.FailedToStart, workerEvent.Snapshot.State?.Text);

23await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 24var terminalState = await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.TerminalStates, cts.Token); 26Assert.Equal(KnownResourceStates.Finished, terminalState); 46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 47var terminalState = await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.TerminalStates, cts.Token); 48Assert.Equal(KnownResourceStates.Finished, terminalState);

335r => r.Snapshot.State?.Text == KnownResourceStates.Finished || 336r.Snapshot.State?.Text == KnownResourceStates.Exited || 337r.Snapshot.State?.Text == KnownResourceStates.FailedToStart, 368if ((exitCode != null && exitCode.Value != 0) || snapshot.State?.Text == KnownResourceStates.FailedToStart)

276State = new ResourceStateSnapshot(KnownResourceStates.NotStarted, KnownResourceStateStyles.Info) 518State = KnownResourceStates.FailedToStart 554State = KnownResourceStates.Starting, 566State = KnownResourceStates.FailedToStart 578State = KnownResourceStates.Running 593var finalState = process.ExitCode == 0 ? KnownResourceStates.Finished : KnownResourceStates.FailedToStart; 633State = KnownResourceStates.FailedToStart, 658State = KnownResourceStates.FailedToStart, 930await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Waiting, KnownResourceStateStyles.Info).ConfigureAwait(false); 934await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Running, KnownResourceStateStyles.Info).ConfigureAwait(false); 950await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.Finished, KnownResourceStateStyles.Info).ConfigureAwait(false); 954await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error).ConfigureAwait(false); 962await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.NotStarted, KnownResourceStateStyles.Info).ConfigureAwait(false); 969await UpdateStateAsync(resourceNotificationService, migrationResource, KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error).ConfigureAwait(false);

51Assert.Equal(KnownResourceStates.Finished, state.Snapshot.State?.Text); 80migrations.Resource.Name, KnownResourceStates.FailedToStart, token); 108migrations.Resource.Name, succeed ? KnownResourceStates.Finished : KnownResourceStates.FailedToStart, token);

204State = new ResourceStateSnapshot(KnownResourceStates.Finished, KnownResourceStateStyles.Info) 234State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Info) 264State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Info) 284State = new ResourceStateSnapshot(KnownResourceStates.Finished, KnownResourceStateStyles.Info)

38State = Result.Success ? KnownResourceStates.Finished : KnownResourceStates.FailedToStart,

351State = new ResourceStateSnapshot(KnownResourceStates.Starting, KnownResourceStateStyles.Info) 371State = KnownResourceStates.Running, 379State = KnownResourceStates.FailedToStart, 449State = KnownResourceStates.Running, 459State = KnownResourceStates.FailedToStart

397KnownResourceStates.Running,

382State = new(KnownResourceStates.Running, KnownResourceStateStyles.Success), 406State = new(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 463KnownResourceStates.Running, 495[KnownResourceStates.Running, .. KnownResourceStates.TerminalStates], 497if (!StringComparers.ResourceState.Equals(state, KnownResourceStates.Running))

929State = KnownResourceStates.FailedToStart

42await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 44await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 50await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

162KnownResourceStates.Running,

44await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 46await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 52await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

38private static readonly ResourceStateSnapshot s_cancelledState = new(KnownResourceStates.Exited, KnownResourceStateStyles.Warn); 470return (releaseOnRunning && string.Equals(state, KnownResourceStates.Running, StringComparisons.ResourceState)) 471|| string.Equals(state, KnownResourceStates.RuntimeUnhealthy, StringComparisons.ResourceState) 472|| KnownResourceStates.TerminalStates.Contains(state, StringComparers.ResourceState) 560e => string.Equals(e.Snapshot.State?.Text, KnownResourceStates.FailedToStart, StringComparisons.ResourceState), 581!string.Equals(s.State.Text, KnownResourceStates.FailedToStart, StringComparisons.ResourceState))

486(KnownResourceStates.TerminalStates.Contains(state, StringComparers.ResourceState) || 490string.Equals(state, KnownResourceStates.RuntimeUnhealthy, StringComparisons.ResourceState));

579var exitedSeen = WaitForStateAsync(env, env.Android, KnownResourceStates.Exited); 582State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, KnownResourceStateStyles.Error) 604Assert.Equal(ResourceCommandState.Enabled, stopCommand.UpdateState(CreateUpdateStateContext(env, KnownResourceStates.Running))); 670State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 737State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success)

924State = KnownResourceStates.Running, 1221State = KnownResourceStates.Running 1300[InlineData(nameof(KnownResourceStates.Exited))] 1332State = KnownResourceStates.Running

47var isRunning = update.Snapshot.State?.Text == KnownResourceStates.Running;

100State = KnownResourceStates.Waiting, 118State = KnownResourceStates.FailedToStart, 136State = KnownResourceStates.Starting, 361State = KnownResourceStates.Running, 369State = KnownResourceStates.FailedToStart, 497? s with { State = KnownResourceStates.Exited } 519? s with { State = KnownResourceStates.Starting } 536? s with { State = KnownResourceStates.Running }

29resourceEvent.Snapshot.State?.Text != KnownResourceStates.Running) 60UpdateState = context => context.ResourceSnapshot.State?.Text == KnownResourceStates.Running &&

56await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 58await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 64await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 135await app.ResourceNotifications.WaitForResourceAsync(mongoExpress.Resource.Name, KnownResourceStates.Running, cts.Token);

338State = KnownResourceStates.Running 345State = KnownResourceStates.Exited 350Assert.Equal(KnownResourceStates.Exited, GetReplicaSetState()); 354Assert.Equal(KnownResourceStates.Starting, GetReplicaSetState()); 360Assert.Equal(KnownResourceStates.Starting, GetReplicaSetState()); 364Assert.Equal(KnownResourceStates.Running, GetReplicaSetState());

454await app.ResourceNotifications.WaitForResourceAsync(rs.Resource.Name, KnownResourceStates.FailedToStart, cts.Token);

100await app.ResourceNotifications.WaitForResourceAsync(mongoExpress.Resource.Name, KnownResourceStates.Running, cts.Token); 162await app.ResourceNotifications.WaitForResourceAsync(consumer.Resource.Name, KnownResourceStates.Waiting, ready.Token); 167update => update.Snapshot.State?.Text == KnownResourceStates.Exited, ready.Token); 207await app.ResourceNotifications.WaitForResourceAsync(mongo1.Resource.Name, KnownResourceStates.Exited, restart.Token); 209await app.ResourceNotifications.WaitForResourceAsync(mongo1.Resource.Name, KnownResourceStates.Running, restart.Token); 217await app.ResourceNotifications.WaitForResourceAsync(mongo1.Resource.Name, KnownResourceStates.Exited, stop.Token);

40[InlineData(nameof(KnownResourceStates.Running), "container-id", ResourceCommandState.Enabled)] 41[InlineData(nameof(KnownResourceStates.Running), null, ResourceCommandState.Disabled)] 42[InlineData(nameof(KnownResourceStates.Running), "", ResourceCommandState.Disabled)] 43[InlineData(nameof(KnownResourceStates.Starting), "container-id", ResourceCommandState.Disabled)] 44[InlineData(nameof(KnownResourceStates.Exited), "container-id", ResourceCommandState.Disabled)] 68[InlineData(nameof(KnownResourceStates.Exited), "container-id", "The container is not running.")] 69[InlineData(nameof(KnownResourceStates.Running), null, "The container ID is not available yet.")]

29resourceEvent.Snapshot.State?.Text != KnownResourceStates.Running) 60UpdateState = context => context.ResourceSnapshot.State?.Text == KnownResourceStates.Running &&

51await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 53await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 59await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

40[InlineData(nameof(KnownResourceStates.Running), "container-id", ResourceCommandState.Enabled)] 41[InlineData(nameof(KnownResourceStates.Running), null, ResourceCommandState.Disabled)] 42[InlineData(nameof(KnownResourceStates.Running), "", ResourceCommandState.Disabled)] 43[InlineData(nameof(KnownResourceStates.Starting), "container-id", ResourceCommandState.Disabled)] 44[InlineData(nameof(KnownResourceStates.Exited), "container-id", ResourceCommandState.Disabled)] 68[InlineData(nameof(KnownResourceStates.Exited), "container-id", "The container is not running.")] 69[InlineData(nameof(KnownResourceStates.Running), null, "The container ID is not available yet.")]

349await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 351await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 357await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

70State = KnownResourceStates.Waiting, 86State = KnownResourceStates.Running, 119State = KnownResourceStates.Waiting, 132State = KnownResourceStates.Running,

43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token); 90await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 92await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 98await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

467await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 469await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 475await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

29resourceEvent.Snapshot.State?.Text != KnownResourceStates.Running) 60UpdateState = context => context.ResourceSnapshot.State?.Text == KnownResourceStates.Running &&

54await app.ResourceNotifications.WaitForResourceAsync(postgres.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 57await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 66await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

40[InlineData(nameof(KnownResourceStates.Running), "container-id", ResourceCommandState.Enabled)] 41[InlineData(nameof(KnownResourceStates.Running), null, ResourceCommandState.Disabled)] 42[InlineData(nameof(KnownResourceStates.Running), "", ResourceCommandState.Disabled)] 43[InlineData(nameof(KnownResourceStates.Starting), "container-id", ResourceCommandState.Disabled)] 44[InlineData(nameof(KnownResourceStates.Exited), "container-id", ResourceCommandState.Disabled)] 68[InlineData(nameof(KnownResourceStates.Exited), "container-id", "The container is not running.")] 69[InlineData(nameof(KnownResourceStates.Running), null, "The container ID is not available yet.")]

115await app.ResourceNotifications.WaitForResourceAsync("pyproj", KnownResourceStates.Finished).WaitAsync(timeout);

278await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 280await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 286await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

43await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 45await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 51await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan);

29resourceEvent.Snapshot.State?.Text != KnownResourceStates.Running) 60UpdateState = context => context.ResourceSnapshot.State?.Text == KnownResourceStates.Running &&

53await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 55await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, 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);

40[InlineData(nameof(KnownResourceStates.Running), "container-id", ResourceCommandState.Enabled)] 41[InlineData(nameof(KnownResourceStates.Running), null, ResourceCommandState.Disabled)] 42[InlineData(nameof(KnownResourceStates.Running), "", ResourceCommandState.Disabled)] 43[InlineData(nameof(KnownResourceStates.Starting), "container-id", ResourceCommandState.Disabled)] 44[InlineData(nameof(KnownResourceStates.Exited), "container-id", ResourceCommandState.Disabled)] 68[InlineData(nameof(KnownResourceStates.Exited), "container-id", "The container is not running.")] 69[InlineData(nameof(KnownResourceStates.Running), null, "The container ID is not available yet.")]

29resourceEvent.Snapshot.State?.Text != KnownResourceStates.Running) 60UpdateState = context => context.ResourceSnapshot.State?.Text == KnownResourceStates.Running &&

46await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 48await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 54await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

40[InlineData(nameof(KnownResourceStates.Running), "container-id", ResourceCommandState.Enabled)] 41[InlineData(nameof(KnownResourceStates.Running), null, ResourceCommandState.Disabled)] 42[InlineData(nameof(KnownResourceStates.Running), "", ResourceCommandState.Disabled)] 43[InlineData(nameof(KnownResourceStates.Starting), "container-id", ResourceCommandState.Disabled)] 44[InlineData(nameof(KnownResourceStates.Exited), "container-id", ResourceCommandState.Disabled)] 68[InlineData(nameof(KnownResourceStates.Exited), "container-id", "The container is not running.")] 69[InlineData(nameof(KnownResourceStates.Running), null, "The container ID is not available yet.")]

107resourceEvent => resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running,

67Assert.Equal(KnownResourceStates.NotStarted, state.State?.Text);

1482State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 1521State = new ResourceStateSnapshot(KnownResourceStates.Running, KnownResourceStateStyles.Success) 2213State = KnownResourceStates.Running,

75State = KnownResourceStates.Running,

148await app.ResourceNotifications.WaitForResourceAsync(c.Resource.Name, KnownResourceStates.Running) 182await app.ResourceNotifications.WaitForResourceAsync(resourceName, KnownResourceStates.Running)

729Assert.Equal(KnownResourceStates.NotStarted, snapshot.State?.Text); 744Assert.Equal(KnownResourceStates.NotStarted, status.State); 759Assert.Equal(KnownResourceStates.NotStarted, snapshot.State?.Text); 774Assert.Equal(KnownResourceStates.NotStarted, status.State);

209var resourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 213await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 217await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 221await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 225await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 255var notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 256var dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, 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); 298await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Finished, 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, startupToken).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 356await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, startupToken).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 397var notStartedResourceEvent = await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 406await rns.WaitForResourceAsync(explicitStartResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.DefaultOrchestratorTestTimeout); 551e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, 556e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, 578var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 585var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 594await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 598await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 640notStartedResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.NotStarted, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 641dependentResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Waiting, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 663var runningResourceEvent = await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 670var dependentRunningResourceEvent = await rns.WaitForResourceAsync(dependentResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 679await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 686await rns.WaitForResourceAsync(notStartedResourceName, e => e.Snapshot.State?.Text == KnownResourceStates.Running, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan); 1111var dependentRunningResourceEvent = await rns.WaitForResourceAsync(container.Resource.Name, e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(TestConstants.LongTimeoutTimeSpan); 2062await app.ResourceNotifications.WaitForResourceAsync(container.Resource.Name, KnownResourceStates.NotStarted, token) 2064await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.NotStarted, token) 2132return state == KnownResourceStates.Exited || state == ContainerState.Unknown; 2137return state == KnownResourceStates.Finished || state == ExecutableState.Terminated; 2172e => e.Snapshot.State?.Text == KnownResourceStates.Running && 2177e => e.Snapshot.State?.Text == KnownResourceStates.Running && 2321await rns.WaitForResourceAsync(containerResourceName, KnownResourceStates.Exited, token).DefaultTimeout(TestConstants.ExtraLongTimeoutTimeSpan);

359await app.ResourceNotifications.WaitForResourceAsync("redis", KnownResourceStates.Running).DefaultTimeout();

343e => e.Snapshot.State?.Text == KnownResourceStates.FailedToStart 347Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.State?.Text); 370e => e.Snapshot.State?.Text == KnownResourceStates.FailedToStart 374Assert.Equal(KnownResourceStates.FailedToStart, resourceEvent.Snapshot.State?.Text); 397e => e.Snapshot.State?.Text == KnownResourceStates.Running 401Assert.Equal(KnownResourceStates.Running, resourceEvent.Snapshot.State?.Text);

35State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 38var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 43State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 75State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 78var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 83State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 86var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 118State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 121var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).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) 180State = new ResourceStateSnapshot(KnownResourceStates.Exited, 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) 584State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 587var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 592State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 596var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout(); 630State = new ResourceStateSnapshot(KnownResourceStates.Starting, null) 633var startingEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Starting).DefaultTimeout(); 638State = new ResourceStateSnapshot(KnownResourceStates.Running, null) 641var runningEvent = await app.ResourceNotifications.WaitForResourceAsync("resource", e => e.Snapshot.State?.Text == KnownResourceStates.Running).DefaultTimeout();

137await rns.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 139await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 145await rns.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);

34State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null), 73State = new ResourceStateSnapshot(KnownResourceStates.Exited, null), 104State = new ResourceStateSnapshot(KnownResourceStates.Exited, null), 145State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null), 183State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null), 198State = new ResourceStateSnapshot(KnownResourceStates.FailedToStart, null),

40Assert.Equal(KnownResourceStates.Finished, @event.ResourceEvent.Snapshot.State?.Text); 52await PublishStateAsync(KnownResourceStates.Running, null); 53await PublishStateAsync(KnownResourceStates.Finished, KnownResourceStates.Running); 56await PublishStateAsync(KnownResourceStates.Finished, KnownResourceStates.Finished); 59await PublishStateAsync(KnownResourceStates.Exited, KnownResourceStates.Finished); 60await PublishStateAsync(KnownResourceStates.FailedToStart, KnownResourceStates.Exited); 63await PublishStateAsync(KnownResourceStates.Running, KnownResourceStates.FailedToStart); 64await PublishStateAsync(KnownResourceStates.Finished, KnownResourceStates.Running); 70snapshot => snapshot with { State = state is not null ? new(state, null) : snapshot.State, ExitCode = state == KnownResourceStates.Finished ? 0 : null })); 565Assert.Equal(KnownResourceStates.FailedToStart, snapshotEvent.Snapshot.State?.Text); 593Assert.Equal(KnownResourceStates.FailedToStart, snapshotEvent.Snapshot.State?.Text); 617Assert.Equal(KnownResourceStates.Starting, snapshotEvent.Snapshot.State?.Text); 645await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Waiting, TestContext.Current.CancellationToken).DefaultTimeout(); 649Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 653await resourceNotificationService.WaitForResourceAsync(blocker.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 654await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 687await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Waiting, TestContext.Current.CancellationToken).DefaultTimeout(); 690Assert.NotEqual(KnownResourceStates.Running, dependencyEvent.Snapshot.State?.Text); 694await resourceNotificationService.WaitForResourceAsync(dependency.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 730State = KnownResourceStates.Running 738e => e.ResourceId == "waiter-abc123" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 745State = KnownResourceStates.Building 788await PublishReplicaStatesAsync(resourceNotificationService, waiter.Resource, KnownResourceStates.NotStarted); 796e => e.ResourceId == "waiter-abc123" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 800Assert.Equal(KnownResourceStates.NotStarted, siblingEvent.Snapshot.State?.Text); 840await PublishReplicaStatesAsync(resourceNotificationService, waiter.Resource, KnownResourceStates.NotStarted); 847e => e.ResourceId == "waiter-abc123" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 893await PublishReplicaStatesAsync(resourceNotificationService, waiter.Resource, KnownResourceStates.NotStarted); 901e => e.ResourceId == "waiter-abc123" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 909e => e.ResourceId == "waiter-def456" && e.Snapshot.State?.Text == KnownResourceStates.Waiting, 955await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Waiting, TestContext.Current.CancellationToken).DefaultTimeout(); 958await resourceNotificationService.PublishUpdateAsync(waiter.Resource, s => s with { State = KnownResourceStates.Starting }).DefaultTimeout(); 960await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 963Assert.NotEqual(KnownResourceStates.Running, blockerEvent.Snapshot.State?.Text); 1008[KnownResourceStates.NotStarted, KnownResourceStates.Waiting], 1012|| waiterEvent.Snapshot.State?.Text != KnownResourceStates.Waiting) 1018await resourceNotificationService.PublishUpdateAsync(waiter.Resource, s => s with { State = KnownResourceStates.Starting }); 1026await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, cancellationToken).DefaultTimeout(); 1029Assert.NotEqual(KnownResourceStates.Running, blockerEvent.Snapshot.State?.Text); 1059await resourceNotificationService.WaitForResourceAsync(connectionString.Resource.Name, KnownResourceStates.Waiting, TestContext.Current.CancellationToken).DefaultTimeout(); 1063await resourceNotificationService.WaitForResourceAsync(referenced.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1064await resourceNotificationService.WaitForResourceAsync(connectionString.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1096re => re.Snapshot.State?.Text == KnownResourceStates.Waiting, 1106await resourceNotificationService.WaitForResourceAsync(blocker.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1107await resourceNotificationService.WaitForResourceAsync(waiter.Resource.Name, KnownResourceStates.Running, TestContext.Current.CancellationToken).DefaultTimeout(); 1126/// <see cref="KnownResourceStates.NotStarted"/> and publishes <see cref="BeforeResourceStartedEvent"/> itself 1135State = KnownResourceStates.NotStarted, 1153State = KnownResourceStates.Running, 1359new ResourceStatus(KnownResourceStates.FailedToStart, null, null), 1361snapshot => snapshot with { State = KnownResourceStates.FailedToStart })); 1369Assert.Equal(KnownResourceStates.FailedToStart, parentState); 1372Assert.NotEqual(KnownResourceStates.Running, childContainerState); 1375Assert.Equal(KnownResourceStates.FailedToStart, customChildState); 1407new ResourceStatus(KnownResourceStates.FailedToStart, null, null), 1409snapshot => snapshot with { State = KnownResourceStates.FailedToStart })); 1417Assert.Equal(KnownResourceStates.FailedToStart, parentState); 1420Assert.NotEqual(KnownResourceStates.Running, childProjectState); 1423Assert.Equal(KnownResourceStates.FailedToStart, customChildState);

104Assert.Equal(KnownResourceStates.Running, snapshot.State?.Text); 144Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 340Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 344Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 348Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2075Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2114Assert.Equal(KnownResourceStates.ValueMissing, updates.Current.Snapshot.State?.Text); 2264Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2282Assert.Equal(KnownResourceStates.ValueMissing, updates.Current.Snapshot.State?.Text); 2294Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2315Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2332Assert.Equal(KnownResourceStates.ValueMissing, updates.Current.Snapshot.State?.Text); 2344Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2363Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2370Assert.Equal(KnownResourceStates.ValueMissing, updates.Current.Snapshot.State?.Text); 2415Assert.Equal(clearValue ? KnownResourceStates.ValueMissing : KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2450Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text); 2457Assert.Equal(KnownResourceStates.ValueMissing, updates.Current.Snapshot.State?.Text); 2484Assert.Equal(KnownResourceStates.ValueMissing, updates.Current.Snapshot.State?.Text); 2491Assert.Equal(KnownResourceStates.Running, updates.Current.Snapshot.State?.Text);

1755await resourceNotificationService.WaitForResourceAsync(project.Resource.Name, e => KnownResourceStates.BuildableStates.Contains(e.Snapshot.State?.Text), cts.Token).DefaultTimeout(TimeSpan.FromMinutes(2));

36await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.Finished, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 59await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout); 90await app.ResourceNotifications.WaitForResourceAsync(executable.Resource.Name, KnownResourceStates.FailedToStart, cts.Token).DefaultTimeout(TestConstants.DefaultOrchestratorTestLongTimeout);

154(snapshot with { State = KnownResourceStates.Running }).WithHealthReports( 309await notificationService.PublishUpdateAsync(resource1, snapshot => snapshot with { State = KnownResourceStates.Running }).DefaultTimeout(); 419re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 423Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 427State = KnownResourceStates.Running 432re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 440State = KnownResourceStates.Running 467re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 471Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 476State = KnownResourceStates.Running, 485re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 494State = KnownResourceStates.Running, 523re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 527Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 531State = KnownResourceStates.Finished, 537re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 545State = KnownResourceStates.Finished, 569State = KnownResourceStates.NotStarted 577re => re.Snapshot.State?.Text == KnownResourceStates.Waiting, 580Assert.Equal(KnownResourceStates.Waiting, waitingEvent.Snapshot.State?.Text); 585State = KnownResourceStates.Running 592[InlineData(nameof(KnownResourceStates.Running))] 593[InlineData(nameof(KnownResourceStates.Stopping))] 594[InlineData(nameof(KnownResourceStates.Building))] 595[InlineData(nameof(KnownResourceStates.Finished))] 596[InlineData(nameof(KnownResourceStates.Exited))] 597[InlineData(nameof(KnownResourceStates.FailedToStart))] 617State = KnownResourceStates.Running 645State = KnownResourceStates.Starting 649State = KnownResourceStates.NotStarted 657re => re.ResourceId == "resource-abc123" && re.Snapshot.State?.Text == KnownResourceStates.Waiting, 661Assert.Equal(KnownResourceStates.NotStarted, notStartedEvent.Snapshot.State?.Text); 665State = KnownResourceStates.Running 671Assert.Equal(KnownResourceStates.NotStarted, notStartedEvent.Snapshot.State?.Text); 687State = KnownResourceStates.NotStarted 695State = KnownResourceStates.Running 701Assert.Equal(KnownResourceStates.NotStarted, notStartedEvent.Snapshot.State?.Text); 720State = KnownResourceStates.NotStarted 728re => re.Snapshot.State?.Text == KnownResourceStates.Waiting, 735State = KnownResourceStates.Running 759State = KnownResourceStates.NotStarted 767re => re.ResourceId == "resource-abc123" && re.Snapshot.State?.Text == KnownResourceStates.Waiting, 774State = KnownResourceStates.Running 799re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 807State = KnownResourceStates.Running 812re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 820State = KnownResourceStates.Running 837State = KnownResourceStates.Waiting, 846State = KnownResourceStates.Running 862State = KnownResourceStates.Running 867State = KnownResourceStates.Waiting, 872var waitTask = notificationService.WaitForResourceAsync(resource.Name, KnownResourceStates.Running, cts.Token); 895State = KnownResourceStates.Starting 903re => re.Snapshot.State?.Text == KnownResourceStates.Waiting && 1215Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Starting)); 1217Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.FailedToStart, exitCode: 1)); 1229Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1231Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 1)); 1232Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 1)); 1234Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 0)); 1235Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 0)); 1247Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1249Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 1)); 1250Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 1)); 1252Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 456)); 1253Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 456)); 1265Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 0)); 1267Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 5)); 1279Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 2)); 1281Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Exited, exitCode: 7)); 1294Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1297Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 0)); 1300Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Starting, exitCode: 0)); 1303Assert.False(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Running)); 1306Assert.True(await PublishAndGetIsHiddenAsync(notificationService, resourceBuilder, KnownResourceStates.Finished, exitCode: 0)); 1326State = KnownResourceStates.Running 1332State = KnownResourceStates.Running, 1371State = KnownResourceStates.Running, 1396State = KnownResourceStates.Running 1404State = KnownResourceStates.Running, 1430State = KnownResourceStates.Running, 1453State = KnownResourceStates.Starting 1460return resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running; 1467State = KnownResourceStates.Running 1470Assert.Equal(KnownResourceStates.Running, (await waitTask.DefaultTimeout()).Snapshot.State?.Text); 1493State = KnownResourceStates.Running 1503return resourceEvent.Snapshot.State?.Text == KnownResourceStates.Running; 1507Assert.Equal(KnownResourceStates.Running, (await waitTask).Snapshot.State?.Text); 1541State = KnownResourceStates.Running 1559State = KnownResourceStates.Running 1581State = KnownResourceStates.Running 1602State = KnownResourceStates.Running, 1620State = KnownResourceStates.Running, 1637State = KnownResourceStates.Running, 1653State = KnownResourceStates.Running, 1658State = KnownResourceStates.FailedToStart

33await app.ResourceNotifications.WaitForResourceAsync(throwingResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 34await app.ResourceNotifications.WaitForResourceAsync(dependingContainerResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 35await app.ResourceNotifications.WaitForResourceAsync(dependingExecutableResource.Resource.Name, KnownResourceStates.FailedToStart, abortCts.Token); 108await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 112State = KnownResourceStates.Running 139await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 143State = KnownResourceStates.Running 176await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 183State = KnownResourceStates.Running 196[InlineData(nameof(KnownResourceStates.Exited))] 197[InlineData(nameof(KnownResourceStates.FailedToStart))] 198[InlineData(nameof(KnownResourceStates.RuntimeUnhealthy))] 199[InlineData(nameof(KnownResourceStates.Finished))] 217await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 224await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token); 307[InlineData(nameof(KnownResourceStates.Exited))] 308[InlineData(nameof(KnownResourceStates.FailedToStart))] 309[InlineData(nameof(KnownResourceStates.RuntimeUnhealthy))] 310[InlineData(nameof(KnownResourceStates.Finished))] 328await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 335await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, waitingStateCts.Token); 341[InlineData(nameof(KnownResourceStates.Exited))] 342[InlineData(nameof(KnownResourceStates.FailedToStart))] 343[InlineData(nameof(KnownResourceStates.RuntimeUnhealthy))] 344[InlineData(nameof(KnownResourceStates.Finished))] 362await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 369await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 374State = KnownResourceStates.Running 377await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 383[InlineData(nameof(KnownResourceStates.Exited))] 384[InlineData(nameof(KnownResourceStates.FailedToStart))] 385[InlineData(nameof(KnownResourceStates.RuntimeUnhealthy))] 386[InlineData(nameof(KnownResourceStates.Finished))] 409await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 416await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 421State = KnownResourceStates.Running 424await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 454await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 461State = KnownResourceStates.Finished, 469await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token); 508State = KnownResourceStates.Finished, 516await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 563State = KnownResourceStates.Running 572await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 610await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 617State = KnownResourceStates.Finished, 624await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.FailedToStart, runningStateCts.Token); 661await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 666State = KnownResourceStates.Running, 669await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 674State = KnownResourceStates.Running, 677await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 714await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 719State = KnownResourceStates.Finished, 722await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 727State = KnownResourceStates.Finished, 730await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 763await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 768State = KnownResourceStates.Finished 771await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, waitingStateCts.Token); 875await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Waiting, waitingStateCts.Token); 880State = KnownResourceStates.Running 885await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.Running, runningStateCts.Token);

629State = KnownResourceStates.Running 631await app.ResourceNotifications.WaitForResourceAsync(serviceA.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 952State = KnownResourceStates.Starting 957e => e.Snapshot.State?.Text == KnownResourceStates.Starting).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 &&

72State = KnownResourceStates.NotStarted, 104State = KnownResourceStates.Running 126if (notification.Snapshot.State == KnownResourceStates.Running && 136await rns.WaitForResourceAsync(custom.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 676e => e.Snapshot.State == KnownResourceStates.Running 715if (notification.Snapshot.State == KnownResourceStates.Running && 725await rns.WaitForResourceAsync(servicea.Resource.Name, KnownResourceStates.Running).DefaultTimeout(); 786e => e.Snapshot.State == KnownResourceStates.Running && e.Snapshot.Urls.Length == 4).DefaultTimeout(); 1119e => e.Snapshot.State == KnownResourceStates.Running 1171e => e.Snapshot.State == KnownResourceStates.Running,

29resourceEvent.Snapshot.State?.Text != KnownResourceStates.Running) 60UpdateState = context => context.ResourceSnapshot.State?.Text == KnownResourceStates.Running &&

40[InlineData(nameof(KnownResourceStates.Running), "container-id", ResourceCommandState.Enabled)] 41[InlineData(nameof(KnownResourceStates.Running), null, ResourceCommandState.Disabled)] 42[InlineData(nameof(KnownResourceStates.Running), "", ResourceCommandState.Disabled)] 43[InlineData(nameof(KnownResourceStates.Starting), "container-id", ResourceCommandState.Disabled)] 44[InlineData(nameof(KnownResourceStates.Exited), "container-id", ResourceCommandState.Disabled)] 68[InlineData(nameof(KnownResourceStates.Exited), "container-id", "The container is not running.")] 69[InlineData(nameof(KnownResourceStates.Running), null, "The container ID is not available yet.")]

227await app.ResourceNotifications.WaitForResourceAsync(resource.Resource.Name, KnownResourceStates.Running, cts.Token); 229await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Waiting, cts.Token); 235await app.ResourceNotifications.WaitForResourceAsync(dependentResource.Resource.Name, KnownResourceStates.Running, cts.Token);

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];

45State = KnownResourceStates.NotStarted, // Use an Aspire well-known state. 79State = KnownResourceStates.Running // Use an Aspire well-known state. 134State = KnownResourceStates.NotStarted,

72await app.ResourceNotifications.WaitForResourceAsync(nginx.Resource.Name, KnownResourceStates.TerminalStates, cancellationToken: cts.Token);