1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16
// SPDX-FileCopyrightText: 2026 Andrei G <bug-ops> // SPDX-License-Identifier: MIT OR Apache-2.0 use std::future::Future; use super::PipelineError; pub trait Step: Send + Sync { type Input: Send; type Output: Send; fn run( &self, input: Self::Input, ) -> impl Future<Output = Result<Self::Output, PipelineError>> + Send; }