pub struct ParallelTaskParams {
pub tasks: Vec<TaskParams>,
pub allow_partial_failure: bool,
pub timeout_ms: Option<u64>,
pub min_success_count: Option<usize>,
}Expand description
Parameters for parallel task execution
Fields§
§tasks: Vec<TaskParams>List of tasks to execute concurrently
allow_partial_failure: boolWhen true, return a successful tool result if at least one child task succeeds. Failed child results are still included in content and metadata.
timeout_ms: Option<u64>Optional total wall-clock timeout for collecting child results.
When the timeout expires, completed child results are returned and any unfinished child is marked as failed in the metadata.
min_success_count: Option<usize>Optional successful child count that is sufficient for the caller.
This only enables early return when allow_partial_failure is true; the
default remains the barrier behavior of waiting for every child.
Trait Implementations§
Source§impl Clone for ParallelTaskParams
impl Clone for ParallelTaskParams
Source§fn clone(&self) -> ParallelTaskParams
fn clone(&self) -> ParallelTaskParams
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for ParallelTaskParams
impl Debug for ParallelTaskParams
Source§impl<'de> Deserialize<'de> for ParallelTaskParams
impl<'de> Deserialize<'de> for ParallelTaskParams
Source§fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>where
__D: Deserializer<'de>,
Deserialize this value from the given Serde deserializer. Read more
Auto Trait Implementations§
impl Freeze for ParallelTaskParams
impl RefUnwindSafe for ParallelTaskParams
impl Send for ParallelTaskParams
impl Sync for ParallelTaskParams
impl Unpin for ParallelTaskParams
impl UnsafeUnpin for ParallelTaskParams
impl UnwindSafe for ParallelTaskParams
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<ST, DT> CastableFrom<ST, Initialized, Initialized> for DT
impl<ST, DT> CastableFrom<ST, Uninit, Uninit> for DT
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> DeserializeOwned for Twhere
T: for<'de> Deserialize<'de>,
Source§impl<T> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more