View Source Handoff.DistributedExecutor (Handoff v0.2.0)
Handles the distributed execution of functions across multiple nodes.
Provides node discovery, coordination, and remote task execution capabilities.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Discovers and registers nodes in the cluster with their capabilities.
Executes the DAG across the distributed nodes.
Link to this section Functions
Returns a specification to start this module under a supervisor.
See Supervisor
.
Discovers and registers nodes in the cluster with their capabilities.
Makes remote calls to discover nodes and their resources.
Executes the DAG across the distributed nodes.
parameters
Parameters
- dag: A validated DAG to execute
- opts: Optional execution options
returns
Returns
{:ok, results}
with a map of function IDs to results on success{:error, reason}
on failure