64 instantiations of PipelineStep
Aspire.Hosting (11)
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)
158 references to PipelineStep
Aspire.Hosting (107)
Pipelines\DistributedApplicationPipeline.cs (61)
25private readonly List<PipelineStep> _steps = [];
29private List<PipelineStep>? _lastResolvedSteps;
178var step = new PipelineStep
197private static void AddDependencies(PipelineStep step, object dependsOn)
218private static void AddRequiredBy(PipelineStep step, object requiredBy)
239public void AddStep(PipelineStep step)
290List<PipelineStep> steps,
291Dictionary<string, PipelineStep> stepsByName)
293foreach (var step in steps)
297if (!stepsByName.TryGetValue(requiredByStep, out var requiredByStepObj))
313private static (List<PipelineStep> StepsToExecute, Dictionary<string, PipelineStep> StepsByName) FilterStepsForExecution(
314List<PipelineStep> allSteps,
326if (!allStepsByName.TryGetValue(stepName, out var targetStep))
342private static List<PipelineStep> ComputeTransitiveDependencies(
343PipelineStep step,
344Dictionary<string, PipelineStep> stepsByName)
347var result = new List<PipelineStep>();
356if (!stepsByName.TryGetValue(stepName, out var currentStep))
375private static async Task<List<PipelineStep>> CollectStepsFromAnnotationsAsync(PipelineContext context)
377var steps = new List<PipelineStep>();
393foreach (var step in annotationSteps)
406List<PipelineStep> allSteps)
440private static void ValidateSteps(IEnumerable<PipelineStep> steps)
444foreach (var step in steps)
453foreach (var step in steps)
480List<PipelineStep> steps,
481Dictionary<string, PipelineStep> stepsByName,
499foreach (var step in steps)
505async Task ExecuteStepWithDependencies(PipelineStep step)
595var step = steps[i];
676List<PipelineStep> steps,
677Dictionary<string, PipelineStep> stepsByName)
683foreach (var step in steps)
711if (stepsByName.TryGetValue(stepName, out var step))
725foreach (var step in steps)
734private static async Task ExecuteStepAsync(PipelineStep step, PipelineStepContext stepContext)
753List<PipelineStep> allSteps,
786var step = executionOrder[i];
798foreach (var step in allSteps.OrderBy(s => s.Name, StringComparer.Ordinal))
848foreach (var step in allSteps)
870foreach (var step in orphanedSteps)
890foreach (var targetStep in allSteps.OrderBy(s => s.Name, StringComparer.Ordinal))
949PipelineStep step,
950Dictionary<string, PipelineStep> stepsByName,
964if (stepsByName.TryGetValue(depName, out var depStep))
979private static int GetExecutionLevel(PipelineStep step, Dictionary<string, PipelineStep> stepsByName)
989List<PipelineStep> steps,
990Dictionary<string, PipelineStep> stepsByName)
994foreach (var step in steps)
1003PipelineStep step,
1004Dictionary<string, PipelineStep> stepsByName,
1022if (stepsByName.TryGetValue(depName, out var depStep))
1036private static List<PipelineStep> GetTopologicalOrder(List<PipelineStep> steps)
1040var result = new List<PipelineStep>();
1042void Visit(PipelineStep step)
1053if (stepsByName.TryGetValue(depName, out var depStep))
1064foreach (var step in sortedSteps)
1085foreach (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 (18)
Publishers.AppHost (1)