diff --git a/cmd/broker/provisioning.go b/cmd/broker/provisioning.go index 970a91ba47..0111b2aee9 100644 --- a/cmd/broker/provisioning.go +++ b/cmd/broker/provisioning.go @@ -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 { diff --git a/internal/process/provisioning/generate_runtime_id_step.go b/internal/process/provisioning/generate_runtime_id_step.go index 509cd8399d..fa6669fa6b 100644 --- a/internal/process/provisioning/generate_runtime_id_step.go +++ b/internal/process/provisioning/generate_runtime_id_step.go @@ -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, } } diff --git a/internal/process/provisioning/generate_runtime_id_step_test.go b/internal/process/provisioning/generate_runtime_id_step_test.go index 39a6c79923..e714733c92 100644 --- a/internal/process/provisioning/generate_runtime_id_step_test.go +++ b/internal/process/provisioning/generate_runtime_id_step_test.go @@ -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"}) @@ -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"})