Skip to content

Commit

Permalink
rebase
Browse files Browse the repository at this point in the history
test corrected

test corrected again
  • Loading branch information
jaroslaw-pieszka committed Jul 18, 2024
1 parent 9461f9b commit f8b27ed
Show file tree
Hide file tree
Showing 3 changed files with 8 additions and 10 deletions.
2 changes: 1 addition & 1 deletion cmd/broker/provisioning.go
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,7 @@ func NewProvisioningProcessingQueue(ctx context.Context, provisionManager *proce
},
{
stage: createRuntimeStageName,
step: provisioning.NewGenerateRuntimeIDStep(db.Operations(), db.RuntimeStates(), db.Instances()),
step: provisioning.NewGenerateRuntimeIDStep(db.Operations(), db.Instances()),
},
// postcondition: operation.RuntimeID is set
{
Expand Down
12 changes: 5 additions & 7 deletions internal/process/provisioning/generate_runtime_id_step.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,16 +15,14 @@ import (
)

type GenerateRuntimeIDStep struct {
operationManager *process.OperationManager
instanceStorage storage.Instances
runtimeStateStorage storage.RuntimeStates
operationManager *process.OperationManager
instanceStorage storage.Instances
}

func NewGenerateRuntimeIDStep(os storage.Operations, runtimeStorage storage.RuntimeStates, is storage.Instances) *GenerateRuntimeIDStep {
func NewGenerateRuntimeIDStep(os storage.Operations, is storage.Instances) *GenerateRuntimeIDStep {
return &GenerateRuntimeIDStep{
operationManager: process.NewOperationManager(os),
instanceStorage: is,
runtimeStateStorage: runtimeStorage,
operationManager: process.NewOperationManager(os),
instanceStorage: is,
}
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ func TestNewGenerateRuntimeIDStep_LeaveRuntimeIDIfNotEmpty(t *testing.T) {
err = memoryStorage.Operations().InsertOperation(operation)
assert.NoError(t, err)

step := NewGenerateRuntimeIDStep(memoryStorage.Operations(), memoryStorage.RuntimeStates(), memoryStorage.Instances())
step := NewGenerateRuntimeIDStep(memoryStorage.Operations(), memoryStorage.Instances())

// when
entry := log.WithFields(logrus.Fields{"step": "TEST"})
Expand Down Expand Up @@ -57,7 +57,7 @@ func TestNewGenerateRuntimeIDStep_LeaveCreateRuntimeIDIfEmpty(t *testing.T) {
err = memoryStorage.Instances().Insert(instance)
assert.NoError(t, err)

step := NewGenerateRuntimeIDStep(memoryStorage.Operations(), memoryStorage.RuntimeStates(), memoryStorage.Instances())
step := NewGenerateRuntimeIDStep(memoryStorage.Operations(), memoryStorage.Instances())

// when
entry := log.WithFields(logrus.Fields{"step": "TEST"})
Expand Down

0 comments on commit f8b27ed

Please sign in to comment.