65 instantiations of PipelineStep
Aspire.Hosting (12)
Aspire.Hosting.Azure (5)
Aspire.Hosting.Azure.AppContainers (5)
Aspire.Hosting.Azure.AppService (5)
Aspire.Hosting.Docker (4)
Aspire.Hosting.Kubernetes (1)
Aspire.Hosting.Tests (32)
Publishers.AppHost (1)
163 references to PipelineStep
Aspire.Hosting (108)
Pipelines\DistributedApplicationPipeline.cs (62)
24private readonly List<PipelineStep> _steps = [];
28private List<PipelineStep>? _lastResolvedSteps;
42var parameterPromptingStep = new PipelineStep
187var step = new PipelineStep
206private static void AddDependencies(PipelineStep step, object dependsOn)
227private static void AddRequiredBy(PipelineStep step, object requiredBy)
248public void AddStep(PipelineStep step)
299List<PipelineStep> steps,
300Dictionary<string, PipelineStep> stepsByName)
302foreach (var step in steps)
306if (!stepsByName.TryGetValue(requiredByStep, out var requiredByStepObj))
322private static (List<PipelineStep> StepsToExecute, Dictionary<string, PipelineStep> StepsByName) FilterStepsForExecution(
323List<PipelineStep> allSteps,
335if (!allStepsByName.TryGetValue(stepName, out var targetStep))
351private static List<PipelineStep> ComputeTransitiveDependencies(
352PipelineStep step,
353Dictionary<string, PipelineStep> stepsByName)
356var result = new List<PipelineStep>();
365if (!stepsByName.TryGetValue(stepName, out var currentStep))
384private static async Task<List<PipelineStep>> CollectStepsFromAnnotationsAsync(PipelineContext context)
386var steps = new List<PipelineStep>();
402foreach (var step in annotationSteps)
415List<PipelineStep> allSteps)
449private static void ValidateSteps(IEnumerable<PipelineStep> steps)
453foreach (var step in steps)
462foreach (var step in steps)
489List<PipelineStep> steps,
490Dictionary<string, PipelineStep> stepsByName,
508foreach (var step in steps)
514async Task ExecuteStepWithDependencies(PipelineStep step)
604var step = steps[i];
685List<PipelineStep> steps,
686Dictionary<string, PipelineStep> stepsByName)
692foreach (var step in steps)
720if (stepsByName.TryGetValue(stepName, out var step))
734foreach (var step in steps)
743private static async Task ExecuteStepAsync(PipelineStep step, PipelineStepContext stepContext)
762List<PipelineStep> allSteps,
795var step = executionOrder[i];
807foreach (var step in allSteps.OrderBy(s => s.Name, StringComparer.Ordinal))
857foreach (var step in allSteps)
879foreach (var step in orphanedSteps)
899foreach (var targetStep in allSteps.OrderBy(s => s.Name, StringComparer.Ordinal))
958PipelineStep step,
959Dictionary<string, PipelineStep> stepsByName,
973if (stepsByName.TryGetValue(depName, out var depStep))
988private static int GetExecutionLevel(PipelineStep step, Dictionary<string, PipelineStep> stepsByName)
998List<PipelineStep> steps,
999Dictionary<string, PipelineStep> stepsByName)
1003foreach (var step in steps)
1012PipelineStep step,
1013Dictionary<string, PipelineStep> stepsByName,
1031if (stepsByName.TryGetValue(depName, out var depStep))
1045private static List<PipelineStep> GetTopologicalOrder(List<PipelineStep> steps)
1049var result = new List<PipelineStep>();
1051void Visit(PipelineStep step)
1062if (stepsByName.TryGetValue(depName, out var depStep))
1073foreach (var step in sortedSteps)
1094foreach (var step in _steps)
Aspire.Hosting.Azure (5)
Aspire.Hosting.Azure.AppContainers (8)
Aspire.Hosting.Azure.AppService (8)
Aspire.Hosting.Azure.Tests (1)
Aspire.Hosting.Containers.Tests (3)
Aspire.Hosting.Docker (6)
Aspire.Hosting.Kubernetes (1)
Aspire.Hosting.Tests (22)
Publishers.AppHost (1)