Skip to content

Commit

Permalink
var name change
Browse files Browse the repository at this point in the history
Signed-off-by: adarsh0728 <[email protected]>
  • Loading branch information
adarsh0728 committed Feb 27, 2025
1 parent 1e9ed76 commit 627d5a4
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 11 deletions.
6 changes: 3 additions & 3 deletions pkg/apis/numaflow/v1alpha1/const.go
Original file line number Diff line number Diff line change
Expand Up @@ -287,9 +287,9 @@ const (
UDContainerLivezFailureThreshold = 5

//Runtime Info
EmptyDirVolume = "tmp-vol"
EmptyDirMountPath = "/var/numaflow/runtime"
EmptyDirSizeLimit = 20 * 1024 * 1024
RuntimeDirVolume = "tmp-vol"
RuntimeDirMountPath = "/var/numaflow/runtime"
RuntimeDirSizeLimit = 20 * 1024 * 1024
)

var (
Expand Down
8 changes: 4 additions & 4 deletions pkg/apis/numaflow/v1alpha1/mono_vertex_types.go
Original file line number Diff line number Diff line change
Expand Up @@ -340,9 +340,9 @@ func (mv MonoVertex) GetPodSpec(req GetMonoVertexPodSpecReq) (*corev1.PodSpec, e
}},
},
{
Name: EmptyDirVolume,
Name: RuntimeDirVolume,
VolumeSource: corev1.VolumeSource{EmptyDir: &corev1.EmptyDirVolumeSource{
SizeLimit: resource.NewQuantity(EmptyDirSizeLimit, resource.BinarySI),
SizeLimit: resource.NewQuantity(RuntimeDirSizeLimit, resource.BinarySI),
}},
},
}
Expand Down Expand Up @@ -400,8 +400,8 @@ func (mv MonoVertex) GetPodSpec(req GetMonoVertexPodSpecReq) (*corev1.PodSpec, e

// Attach an EmptyDir for runtime info
containers[0].VolumeMounts = append(containers[0].VolumeMounts, corev1.VolumeMount{
Name: EmptyDirVolume,
MountPath: EmptyDirMountPath,
Name: RuntimeDirVolume,
MountPath: RuntimeDirMountPath,
})

for i := 0; i < len(sidecarContainers); i++ { // udsink, udsource, udtransformer ...
Expand Down
8 changes: 4 additions & 4 deletions pkg/apis/numaflow/v1alpha1/vertex_types.go
Original file line number Diff line number Diff line change
Expand Up @@ -270,9 +270,9 @@ func (v Vertex) GetPodSpec(req GetVertexPodSpecReq) (*corev1.PodSpec, error) {
}},
},
{
Name: EmptyDirVolume,
Name: RuntimeDirVolume,
VolumeSource: corev1.VolumeSource{EmptyDir: &corev1.EmptyDirVolumeSource{
SizeLimit: resource.NewQuantity(EmptyDirSizeLimit, resource.BinarySI),
SizeLimit: resource.NewQuantity(RuntimeDirSizeLimit, resource.BinarySI),
}},
},
}
Expand Down Expand Up @@ -336,8 +336,8 @@ func (v Vertex) GetPodSpec(req GetVertexPodSpecReq) (*corev1.PodSpec, error) {

// Attach an EmptyDir for runtime info
containers[0].VolumeMounts = append(containers[0].VolumeMounts, corev1.VolumeMount{
Name: EmptyDirVolume,
MountPath: EmptyDirMountPath,
Name: RuntimeDirVolume,
MountPath: RuntimeDirMountPath,
})

for i := 0; i < len(sidecarContainers); i++ { // udf, udsink, udsource, or source vertex specifies a udtransformer
Expand Down

0 comments on commit 627d5a4

Please sign in to comment.