Skip to content

Commit

Permalink
revert change to tracking file dir
Browse files Browse the repository at this point in the history
  • Loading branch information
jharrod authored Feb 4, 2025
1 parent 0cb47a9 commit b299be8
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
2 changes: 1 addition & 1 deletion frontend/csi/node_helpers/kubernetes/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,7 +53,7 @@ func NewHelper(orchestrator core.Orchestrator, kubeConfigPath string, enableForc
return nil, fmt.Errorf("could not initialize mount client; %v", err)
}

publishManager, err := csi.NewVolumePublishManager()
publishManager, err := csi.NewVolumePublishManager(config.VolumeTrackingInfoPath)
if err != nil {
return nil, fmt.Errorf("could not initialize VolumePublishManager; %v", err)
}
Expand Down
2 changes: 1 addition & 1 deletion frontend/csi/node_helpers/plain/plugin.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ func NewHelper(orchestrator core.Orchestrator) (frontend.Plugin, error) {

Logc(ctx).Info("Initializing plain CSI helper frontend.")

publishManager, err := csi.NewVolumePublishManager()
publishManager, err := csi.NewVolumePublishManager("")
if err != nil {
return nil, fmt.Errorf("could not initialize VolumePublishManager; %v", err)
}
Expand Down
4 changes: 2 additions & 2 deletions frontend/csi/volume_publish_manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,8 +40,8 @@ type VolumePublishManager struct {
osFs afero.Fs
}

func NewVolumePublishManager() (*VolumePublishManager, error) {
infoPath := config.VolumeTrackingInfoPath
func NewVolumePublishManager(volumeTrackingInfoPath string) (*VolumePublishManager, error) {
infoPath := volumeTrackingInfoPath
mountClient, err := mount.New()
if err != nil {
return nil, err
Expand Down

0 comments on commit b299be8

Please sign in to comment.