mirror of
https://github.com/luxfi/lpm.git
synced 2026-10-30 16:20:57 +00:00
zeekay
7d7127a687
- Update node v1.16.15 → v1.19.8 - Update crypto v1.17.0 → v1.17.4 - Update database v1.2.0 → v1.2.1 - Update geth v1.16.34 → v1.16.35 - Update ids v1.1.0 → v1.1.1 - Update Go 1.25 → 1.25.1 - Update copyright year to 2025
34 lines
652 B
Go
34 lines
652 B
Go
// Copyright (C) 2019-2025, Lux Partners Limited. All rights reserved.
|
|
// See the file LICENSE for licensing terms.
|
|
|
|
package engine
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/luxfi/lpm/state"
|
|
"github.com/luxfi/lpm/workflow"
|
|
)
|
|
|
|
var _ workflow.Executor = &WorkflowEngine{}
|
|
|
|
func NewWorkflowEngine(stateFile state.File) *WorkflowEngine {
|
|
return &WorkflowEngine{
|
|
stateFile: stateFile,
|
|
}
|
|
}
|
|
|
|
type WorkflowEngine struct {
|
|
stateFile state.File
|
|
}
|
|
|
|
func (w *WorkflowEngine) Execute(workflow workflow.Workflow) error {
|
|
defer func() {
|
|
if err := w.stateFile.Commit(); err != nil {
|
|
fmt.Printf("failed to commit the statefile")
|
|
}
|
|
}()
|
|
|
|
return workflow.Execute()
|
|
}
|