Struct DynamicMapTask 

pub struct DynamicMapTask<F> { /* private fields */ }

Fans out over a list of child tasks built from context at run time — the same shape as graph_flow::fanout::FanOutTask, except the number and identity of children isn’t fixed until the task actually runs. This is what LangGraph’s Send API covers in Python: “run this step once per item in a list I only know at runtime” (once per retrieved document, once per subtask an LLM just planned out), which a construction-time Vec of children can’t express.

Implementations

impl<F> DynamicMapTask<F>

where F: Fn(&Context) -> Vec<Arc<dyn Task>> + Send + Sync,

pub fn new(id: impl Into<String>, children_fn: F) -> Self

children_fn inspects context and returns the child tasks to run concurrently this time — typically one per item in a list context already holds.

pub fn with_prefix(self, prefix: impl Into<String>) -> Self

Store aggregated child results under <prefix>.<child_id>.response instead of the default map.<child_id>.response.

pub fn with_next_action(self, next_action: NextAction) -> Self

Trait Implementations

impl<F> Task for DynamicMapTask<F>

where F: Fn(&Context) -> Vec<Arc<dyn Task>> + Send + Sync,

fn id(&self) -> &str

Unique identifier for this task.

fn run<'life0, 'async_trait>( &'life0 self, context: Context, ) -> Pin<Box<dyn Future<Output = Result<TaskResult>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Execute the task with the given context.