From c25b36ac7e467078fac590d93bddd455898a245a Mon Sep 17 00:00:00 2001 From: sjtucoder Date: Fri, 7 Feb 2025 14:23:51 +0800 Subject: [PATCH] chore: fix some function names in comment Signed-off-by: sjtucoder --- flyteadmin/pkg/manager/impl/metrics_manager.go | 4 ++-- .../go/tasks/plugins/array/k8s/subtask_exec_context.go | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/flyteadmin/pkg/manager/impl/metrics_manager.go b/flyteadmin/pkg/manager/impl/metrics_manager.go index a689c60a70..97926a31b0 100644 --- a/flyteadmin/pkg/manager/impl/metrics_manager.go +++ b/flyteadmin/pkg/manager/impl/metrics_manager.go @@ -501,7 +501,7 @@ func (m *MetricsManager) parseNodeExecutions(ctx context.Context, nodeExecutions return nil } -// parseSubworkflowNodeExecutions partitions the SubworkflowNode execution into a collection of Categorical and +// parseSubworkflowNodeExecution partitions the SubworkflowNode execution into a collection of Categorical and // Reference Spans which are appended to the provided spans argument. func (m *MetricsManager) parseSubworkflowNodeExecution(ctx context.Context, nodeExecution *admin.NodeExecution, identifier *core.Identifier, spans *[]*core.Span, depth int) error { @@ -606,7 +606,7 @@ func parseTaskExecutions(taskExecutions []*admin.TaskExecution, spans *[]*core.S } } -// parseTaskNodeExecutions partitions the TaskNode execution into a collection of Categorical and Reference Spans which +// parseTaskNodeExecution partitions the TaskNode execution into a collection of Categorical and Reference Spans which // are appended to the provided spans argument. func (m *MetricsManager) parseTaskNodeExecution(ctx context.Context, nodeExecution *admin.NodeExecution, spans *[]*core.Span, depth int) error { // retrieve task executions diff --git a/flyteplugins/go/tasks/plugins/array/k8s/subtask_exec_context.go b/flyteplugins/go/tasks/plugins/array/k8s/subtask_exec_context.go index d0e483257d..82303831ee 100644 --- a/flyteplugins/go/tasks/plugins/array/k8s/subtask_exec_context.go +++ b/flyteplugins/go/tasks/plugins/array/k8s/subtask_exec_context.go @@ -67,7 +67,7 @@ func (s SubTaskExecutionContext) PluginStateReader() pluginsCore.PluginStateRead return pluginStateReader{} } -// NewSubtaskExecutionContext constructs a SubTaskExecutionContext using the provided parameters +// NewSubTaskExecutionContext constructs a SubTaskExecutionContext using the provided parameters func NewSubTaskExecutionContext(ctx context.Context, tCtx pluginsCore.TaskExecutionContext, taskTemplate *core.TaskTemplate, executionIndex, originalIndex int, retryAttempt uint64, systemFailures uint64) (SubTaskExecutionContext, error) {