Skip to main content

Nava Workflow Engine

info

Nava provides workflow orchestration and process management capabilities.

Introduction​

The Nava module enables:

  • Workflow definition and execution
  • Process state management
  • Task orchestration
  • Workflow templates
  • Process monitoring

Quick Start​

Define Workflow​

from fluvius.nava import WorkflowEngine, WorkflowDefinition

workflow_def = WorkflowDefinition(
    name='order-processing',
    steps=[
        {'task': 'validate-order', 'next': 'process-payment'},
        {'task': 'process-payment', 'next': 'fulfill-order'},
        {'task': 'fulfill-order', 'next': 'complete'}
    ]
)

Execute Workflow​

from fluvius.nava import WorkflowEngine

engine = WorkflowEngine()
process_id = await engine.start_workflow('order-processing', initial_data={})

Monitor Process​

status = await engine.get_process_status(process_id)
current_step = status.current_step

Features​

  • Workflow Definition: Define workflows with steps and transitions
  • State Management: Track process state and data
  • Task Execution: Execute tasks within workflows
  • Error Handling: Handle failures and retries
  • Monitoring: Track workflow execution

Next Steps​