Function run_step

pub async fn run_step(
    ctx: &WatchContext,
    step: &Cmd,
    env: &Option<HashMap<String, String>>,
    output_strategy: &OutpuStrategy,
    pipe_registry: Arc<Mutex<PipeRegistry>>,
) -> Result<Option<CommandOutput>>