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.

Link to this function

execute(dag, opts \\ [])

View Source

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