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) {