Skip to content

Commit 1f2c436

Browse files
committed
Fixed flag in volume-poollet and class mapper
1 parent cee72b9 commit 1f2c436

File tree

1 file changed

+2
-2
lines changed
  • poollet/volumepoollet/cmd/volumepoollet/app

1 file changed

+2
-2
lines changed

poollet/volumepoollet/cmd/volumepoollet/app/app.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,7 @@ func Run(ctx context.Context, opts Options) error {
328328
var volumeEvents irievent.Generator[*iri.Volume]
329329
if opts.Switches.Enabled(volumeController) {
330330
setupLog.V(1).Info("Volume controller enabled")
331-
volumeClassMapper := vcm.NewGeneric(volumeRuntime, vcm.GenericOptions{})
331+
volumeClassMapper = vcm.NewGeneric(volumeRuntime, vcm.GenericOptions{})
332332
if err := mgr.Add(volumeClassMapper); err != nil {
333333
return fmt.Errorf("error adding volume class mapper: %w", err)
334334
}
@@ -361,7 +361,7 @@ func Run(ctx context.Context, opts Options) error {
361361
}
362362

363363
var volumeSnapshotEvents irievent.Generator[*iri.VolumeSnapshot]
364-
if opts.Switches.Enabled(volumeController) {
364+
if opts.Switches.Enabled(volumeSnapshotController) {
365365
setupLog.V(1).Info("Volume Snapshot controller enabled")
366366
volumeSnapshotEvents = irievent.NewGenerator(func(ctx context.Context) ([]*iri.VolumeSnapshot, error) {
367367
res, err := volumeRuntime.ListVolumeSnapshots(ctx, &iri.ListVolumeSnapshotsRequest{})

0 commit comments

Comments
 (0)