Run Module

Run Management

RunsManager(adapter: Any, project: ProjectSummary)

Runs manager for a specific project.

Provides run operations like executing workflows without requiring project context on each method call.

Parameters:

Name	Type	Description	Default
adapter	Any	adapter (FluidizeSDK or LocalAdapter)	required
project	ProjectSummary	The project this runs manager is bound to	required

run_flow(payload: RunFlowPayload) -> dict[str, Any]

Execute a flow run for this project.

Parameters:

Name	Type	Description	Default
payload	RunFlowPayload	Run configuration (name, description, tags)	required

Returns:

Type	Description
dict[str, Any]	Dictionary with flow_status and run_number

get_status(run_number: int) -> dict[str, Any]

Get the status of a specific run for this project.

Parameters:

Name	Type	Description	Default
run_number	int	The run number to check	required

Returns:

Type	Description
dict[str, Any]	Dictionary with run status information

Run Execution

RunJob

A job that runs for a single node.

Parameters:

Name	Type	Description	Default
project	ProjectSummary	The project this node belongs to	required
strategyClass	type[BaseExecutionStrategy]	The strategy class to use for execution	required
nodeProperties_simulation	nodeProperties_simulation	The node properties to run	required
prev_nodeProperties_simulation	Optional[nodeProperties_simulation]	The previous node properties (optional)	None
mlflow_tracker	Optional[MLFlowTracker]	The MLflow tracker (optional)	None
run_id	Optional[str]	The run ID (optional)	None
run_metadata	Optional[object]	The run metadata (optional)	None

ProjectRunner(project: ProjectSummary)

Project runner that delegates to registered implementation based on mode.

Follows the same pattern as DataLoader - uses get_handler() to get the appropriate implementation (local, cloud, etc.)

Parameters:

Name	Type	Description	Default
project	ProjectSummary	ProjectSummary	required

prepare_run_environment(metadata: RunFlowPayload) -> int

Create a new run folder for the project.

Parameters:

Name	Type	Description	Default
metadata	RunFlowPayload	RunFlowPayload	required

Returns:

Name	Type	Description
int	int	Run number

execute_node(node_id: str, prev_node_id: Optional[str] = None, **kwargs: Any) -> dict[str, Any] async

Execute a single node within the project run.

Parameters:

Name	Type	Description	Default
node_id	str	Node ID	required
prev_node_id	Optional[str]	Previous node ID	None
**kwargs	Any	Additional keyword arguments	{}

Returns:

Type	Description
dict[str, Any]	dict[str, Any]: Execution result

execute_flow(nodes_to_run: list[str], prev_nodes: list[str], **kwargs: Any) -> list[dict[str, Any]] async

Execute a flow of nodes in order.

Parameters:

Name	Type	Description	Default
nodes_to_run	list[str]	List of node IDs	required
prev_nodes	list[str]	List of previous node IDs	required
**kwargs	Any	Additional keyword arguments	{}

Returns:

Type	Description
list[dict[str, Any]]	list[dict[str, Any]]: Execution results for all nodes