69 instantiations of PipelineStep
Aspire.Hosting (16)
Aspire.Hosting.Azure (5)
Aspire.Hosting.Azure.AppContainers (3)
Aspire.Hosting.Azure.AppService (5)
Aspire.Hosting.Azure.ContainerRegistry (1)
Aspire.Hosting.Docker (5)
Aspire.Hosting.Kubernetes (1)
Aspire.Hosting.Tests (32)
Publishers.AppHost (1)
183 references to PipelineStep
Aspire.Hosting (113)
Pipelines\DistributedApplicationPipeline.cs (63)
26private readonly List<PipelineStep> _steps = [];
30private List<PipelineStep>? _lastResolvedSteps;
45var parameterPromptingStep = new PipelineStep
157var pushStep = new PipelineStep
282var step = new PipelineStep
301private static void AddDependencies(PipelineStep step, object dependsOn)
322private static void AddRequiredBy(PipelineStep step, object requiredBy)
343public void AddStep(PipelineStep step)
394List<PipelineStep> steps,
395Dictionary<string, PipelineStep> stepsByName)
397foreach (var step in steps)
401if (!stepsByName.TryGetValue(requiredByStep, out var requiredByStepObj))
417private static (List<PipelineStep> StepsToExecute, Dictionary<string, PipelineStep> StepsByName) FilterStepsForExecution(
418List<PipelineStep> allSteps,
430if (!allStepsByName.TryGetValue(stepName, out var targetStep))
446private static List<PipelineStep> ComputeTransitiveDependencies(
447PipelineStep step,
448Dictionary<string, PipelineStep> stepsByName)
451var result = new List<PipelineStep>();
460if (!stepsByName.TryGetValue(stepName, out var currentStep))
479private static async Task<List<PipelineStep>> CollectStepsFromAnnotationsAsync(PipelineContext context)
481var steps = new List<PipelineStep>();
497foreach (var step in annotationSteps)
510List<PipelineStep> allSteps)
544private static void ValidateSteps(IEnumerable<PipelineStep> steps)
548foreach (var step in steps)
557foreach (var step in steps)
584List<PipelineStep> steps,
585Dictionary<string, PipelineStep> stepsByName,
603foreach (var step in steps)
609async Task ExecuteStepWithDependencies(PipelineStep step)
699var step = steps[i];
780List<PipelineStep> steps,
781Dictionary<string, PipelineStep> stepsByName)
787foreach (var step in steps)
815if (stepsByName.TryGetValue(stepName, out var step))
829foreach (var step in steps)
838private static async Task ExecuteStepAsync(PipelineStep step, PipelineStepContext stepContext)
857List<PipelineStep> allSteps,
890var step = executionOrder[i];
902foreach (var step in allSteps.OrderBy(s => s.Name, StringComparer.Ordinal))
958foreach (var step in allSteps)
980foreach (var step in orphanedSteps)
1000foreach (var targetStep in allSteps.OrderBy(s => s.Name, StringComparer.Ordinal))
1059PipelineStep step,
1060Dictionary<string, PipelineStep> stepsByName,
1074if (stepsByName.TryGetValue(depName, out var depStep))
1089private static int GetExecutionLevel(PipelineStep step, Dictionary<string, PipelineStep> stepsByName)
1099List<PipelineStep> steps,
1100Dictionary<string, PipelineStep> stepsByName)
1104foreach (var step in steps)
1113PipelineStep step,
1114Dictionary<string, PipelineStep> stepsByName,
1132if (stepsByName.TryGetValue(depName, out var depStep))
1146private static List<PipelineStep> GetTopologicalOrder(List<PipelineStep> steps)
1150var result = new List<PipelineStep>();
1152void Visit(PipelineStep step)
1163if (stepsByName.TryGetValue(depName, out var depStep))
1174foreach (var step in sortedSteps)
1195foreach (var step in _steps)
Aspire.Hosting.Azure (5)
Aspire.Hosting.Azure.AppContainers (6)
Aspire.Hosting.Azure.AppService (8)
Aspire.Hosting.Azure.ContainerRegistry (1)
Aspire.Hosting.Azure.Tests (7)
Aspire.Hosting.Containers.Tests (6)
Aspire.Hosting.Docker (8)
Aspire.Hosting.Kubernetes (1)
Aspire.Hosting.Tests (27)
Publishers.AppHost (1)