Skip to content

Commit

Permalink
unify
Browse files Browse the repository at this point in the history
  • Loading branch information
kruftik committed Mar 23, 2024
1 parent 2a8571b commit 35ce5a0
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 2 deletions.
4 changes: 3 additions & 1 deletion pkg/components/rpcproxy.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,9 @@ func NewRPCProxy(
&resource.ObjectMeta,
consts.RpcProxyType,
consts.YTComponentLabelRPCProxy,
).WithComponentInstanceName(spec.Role).Build()
).
WithComponentInstanceName(spec.Role).
Build()

if spec.InstanceSpec.MonitoringPort == nil {
spec.InstanceSpec.MonitoringPort = ptr.Int32(consts.RPCProxyMonitoringPort)
Expand Down
4 changes: 3 additions & 1 deletion pkg/components/scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,7 +41,9 @@ func NewScheduler(
&resource.ObjectMeta,
consts.SchedulerType,
consts.YTComponentLabelScheduler,
).WithAnnotations(resource.Spec.ExtraPodAnnotations).Build()
).
WithAnnotations(resource.Spec.ExtraPodAnnotations).
Build()

if resource.Spec.Schedulers.InstanceSpec.MonitoringPort == nil {
resource.Spec.Schedulers.InstanceSpec.MonitoringPort = ptr.Int32(consts.SchedulerMonitoringPort)
Expand Down

0 comments on commit 35ce5a0

Please sign in to comment.