View Source Handoff.DataLocationRegistry (Handoff v0.1.0)
Tracks the location (node ID) of every piece of data (argument or intermediate result) for each DAG.
This registry maintains a mapping of {dag_id, data_id} to their hosting nodes, enabling on-demand data fetching from the appropriate node for a specific DAG execution.
Link to this section Summary
Functions
Returns a specification to start this module under a supervisor.
Clears all registered data locations for a specific DAG.
Gets all registered data locations for a specific DAG.
Looks up where a data item is stored for a specific DAG.
Registers a data item with its hosting node for a specific DAG.
Starts the Data Location Registry GenServer.
Link to this section Functions
Returns a specification to start this module under a supervisor.
See Supervisor.
Clears all registered data locations for a specific DAG.
parameters
Parameters
- dag_id: The ID of the DAG
Gets all registered data locations for a specific DAG.
parameters
Parameters
- dag_id: The ID of the DAG
returns
Returns
- A map of data_id => node_id for the specified DAG
Looks up where a data item is stored for a specific DAG.
parameters
Parameters
- dag_id: The ID of the DAG
- data_id: The ID of the data (argument or result)
returns
Returns
{:ok, node_id}if the data location is found for the DAG{:error, :not_found}if the data location is not registered for the DAG
Registers a data item with its hosting node for a specific DAG.
parameters
Parameters
- dag_id: The ID of the DAG
- data_id: The ID of the data (argument or result)
- node_id: The node where the data is stored
Starts the Data Location Registry GenServer.