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)
25private readonly List<PipelineStep> _steps = [];
29private List<PipelineStep>? _lastResolvedSteps;
44var parameterPromptingStep = new PipelineStep
158var pushStep = new PipelineStep
264var step = new PipelineStep
283private static void AddDependencies(PipelineStep step, object dependsOn)
304private static void AddRequiredBy(PipelineStep step, object requiredBy)
325public void AddStep(PipelineStep step)
376List<PipelineStep> steps,
377Dictionary<string, PipelineStep> stepsByName)
379foreach (var step in steps)
383if (!stepsByName.TryGetValue(requiredByStep, out var requiredByStepObj))
399private static (List<PipelineStep> StepsToExecute, Dictionary<string, PipelineStep> StepsByName) FilterStepsForExecution(
400List<PipelineStep> allSteps,
412if (!allStepsByName.TryGetValue(stepName, out var targetStep))
428private static List<PipelineStep> ComputeTransitiveDependencies(
429PipelineStep step,
430Dictionary<string, PipelineStep> stepsByName)
433var result = new List<PipelineStep>();
442if (!stepsByName.TryGetValue(stepName, out var currentStep))
461private static async Task<List<PipelineStep>> CollectStepsFromAnnotationsAsync(PipelineContext context)
463var steps = new List<PipelineStep>();
479foreach (var step in annotationSteps)
492List<PipelineStep> allSteps)
526private static void ValidateSteps(IEnumerable<PipelineStep> steps)
530foreach (var step in steps)
539foreach (var step in steps)
566List<PipelineStep> steps,
567Dictionary<string, PipelineStep> stepsByName,
585foreach (var step in steps)
591async Task ExecuteStepWithDependencies(PipelineStep step)
681var step = steps[i];
762List<PipelineStep> steps,
763Dictionary<string, PipelineStep> stepsByName)
769foreach (var step in steps)
797if (stepsByName.TryGetValue(stepName, out var step))
811foreach (var step in steps)
820private static async Task ExecuteStepAsync(PipelineStep step, PipelineStepContext stepContext)
839List<PipelineStep> allSteps,
872var step = executionOrder[i];
884foreach (var step in allSteps.OrderBy(s => s.Name, StringComparer.Ordinal))
940foreach (var step in allSteps)
962foreach (var step in orphanedSteps)
982foreach (var targetStep in allSteps.OrderBy(s => s.Name, StringComparer.Ordinal))
1041PipelineStep step,
1042Dictionary<string, PipelineStep> stepsByName,
1056if (stepsByName.TryGetValue(depName, out var depStep))
1071private static int GetExecutionLevel(PipelineStep step, Dictionary<string, PipelineStep> stepsByName)
1081List<PipelineStep> steps,
1082Dictionary<string, PipelineStep> stepsByName)
1086foreach (var step in steps)
1095PipelineStep step,
1096Dictionary<string, PipelineStep> stepsByName,
1114if (stepsByName.TryGetValue(depName, out var depStep))
1128private static List<PipelineStep> GetTopologicalOrder(List<PipelineStep> steps)
1132var result = new List<PipelineStep>();
1134void Visit(PipelineStep step)
1145if (stepsByName.TryGetValue(depName, out var depStep))
1156foreach (var step in sortedSteps)
1177foreach (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)