pub fn consume_pipeline_step<I: Span>(input: I) -> Res<I, PipelineStepVar>