fluxion_ai.workflows.workflow_progress_tracker module

fluxion_ai.workflows.workflow_progress_tracker

This module provides a class to track the progress of workflow execution. This class is used to monitor the status of each node in the workflow and calculate the overall progress.

Classes:

WorkflowProgressTracker: Class to track the progress of workflow execution.

class fluxion_ai.workflows.workflow_progress_tracker.WorkflowProgressTracker(node_names: List[str])[source]

Bases: object

Tracks the progress of workflow execution.

get_progress() → Dict[str, Any][source]

Get the current progress of the workflow.

Returns:: Progress details including node status and overall percentage.
Return type:: Dict[str, Any]

mark_node_completed(node_name: str)[source]

Mark a node as completed and record its execution time.

Parameters:: node_name (str) – Name of the node.

mark_node_running(node_name: str)[source]

Mark a node as running.

Parameters:: node_name (str) – Name of the node.

start_workflow()[source]: Mark the start of the workflow execution.