Skip to content

Commit

Permalink
increase timeout period for mgmt api job (#86)
Browse files Browse the repository at this point in the history
* increase timeout period for mgmt api job

* removed CapacityByte from NodeExpandVolumeResponse
  • Loading branch information
geoffrey1330 authored Oct 26, 2024
1 parent 71c92e3 commit c972c2b
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 3 deletions.
2 changes: 1 addition & 1 deletion charts/latest/spdk-csi/templates/config-map.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -76,8 +76,8 @@ data:
return []
def activate_cluster_if_needed(cluster_ip, cluster_uuid, cluster_secret, distr_ndcs, distr_npcs):
retries = 60
total_value = distr_ndcs + distr_npcs + 1
retries = total_value * 30
while retries > 0:
node_statuses = get_node_statuses(cluster_ip, cluster_uuid, cluster_secret)
online_nodes = [node for node in node_statuses if node.get('status') == 'online']
Expand Down
3 changes: 1 addition & 2 deletions pkg/spdk/nodeserver.go
Original file line number Diff line number Diff line change
Expand Up @@ -302,7 +302,6 @@ func (ns *nodeServer) NodeExpandVolume(_ context.Context, req *csi.NodeExpandVol

volumeID := req.GetVolumeId()
volumeMountPath := req.GetVolumePath()
updatedSize := req.GetCapacityRange().GetRequiredBytes()

stagingParentPath := req.GetStagingTargetPath()
volumeContext, err := util.LookupVolumeContext(stagingParentPath)
Expand Down Expand Up @@ -333,7 +332,7 @@ func (ns *nodeServer) NodeExpandVolume(_ context.Context, req *csi.NodeExpandVol
}
}

return &csi.NodeExpandVolumeResponse{CapacityBytes: updatedSize}, nil
return &csi.NodeExpandVolumeResponse{}, nil
}

// must be idempotent
Expand Down

0 comments on commit c972c2b

Please sign in to comment.