How nshaibu/volnux works
Volnux is a workflow orchestration framework: users can define task graphs in Pointy-Lang, build pipeline flows, and execute workflows with conditional, sequential, and parallel task handling. Its broader documented capabilities include hybrid concurrency, distributed execution, extensible signals, and event-driven behavior; the tree also shows persistence backends, telemetry, and adaptive scaling. The sampled engine explicitly dispatches execution contexts, while several integrations and subsystem connections are represented only by their supported entry points because their wiring was not sampled.
Main entry points: pipeline.py Pipeline coordination · build_pipeline_flow.py Flow builder · default_engine.py Workflow engine · context.py Execution context
Components 21
Workflow authoring
- Pointy parser
volnux/parser/__init__.py - Flow builder
volnux/task/build_pipeline_flow.py - Task graph
volnux/task/task.py - Command interface
volnux/cli/main.py - Run workflow
volnux/cli/command/builtins/run_workflow.py
Workflow runtime
- Pipeline coordination
volnux/pipeline.py - Workflow engine
volnux/engine/default_engine.py - Workflow loading
volnux/engine/workflows/loaders - Execution context
volnux/execution/context.py - Execution state
volnux/execution/state_manager.py - Workflow result
volnux/execution/result.py
Task execution
- Task executors
volnux/executors/default_executor.py - Remote execution
volnux/executors/remote_executor.py - Remote managers
volnux/manager
State and integrations
- Backend connectors
volnux/backends/connectors - Backend stores
volnux/backends/stores - Signals and events
volnux/signal/signals.py
Operations
- Telemetry
volnux/telemetry - Adaptive scaling
volnux/scaling/adaptive/engine.py
Other components
- Workflow author
- CLI user
Connections 17
- Workflow author → Flow builder: provides DSL
- Flow builder → Pointy parser: parses code
- Flow builder → Task graph: generates flow
- CLI user → Command interface: runs command
- Command interface → Run workflow: dispatches command
- Run workflow → Pipeline coordination: starts workflow
- Workflow loading → Pipeline coordination: loads workflow
- Pipeline coordination → Workflow engine: executes workflow
- Workflow engine → Execution context: dispatches context
- Execution context → Task executors: runs tasks
- Workflow engine → Workflow result: produces result
- Execution context → Execution state: records state
- Remote execution → Remote managers: sends tasks
- Backend connectors → Backend stores: connects storage
- Pipeline coordination → Signals and events: emits lifecycle events
- Pipeline coordination → Telemetry: reports execution
- Task executors → Adaptive scaling: scales workers