New RunLLM response generated:
>>>*# Question*
He...
# runllm-flyte-triala
ancient-wolf-19325
08/05/2024, 1:09 PMNew RunLLM response generated:
>>>*# Question*
Hello again. Trying to understand pod plugin development, so to take it as reference to develop other custom backend plugins for our need on k8s.
Need some help to understanding links between functions calls and their definitions.
currently, taskCtx.TaskReader().Read(ctx) is referring to an interface. But where the implementation for this interface. I see it called BuildResource method. Could some can explain us code?
# Answer
The
taskCtx.TaskReader().Read(ctx)TaskReaderTaskReader Copy code
type TaskReader interface {
Read(ctx context.Context) (*core.TaskTemplate, error)
}TaskReaderTaskExecutionContextTaskReaderBuildResourceBuildResourceTaskReader Copy code
func (p plugin) BuildResource(ctx context.Context, taskCtx pluginsCore.TaskExecutionContext) (client.Object, error) {
taskTemplate, err := taskCtx.TaskReader().Read(ctx)
if err != nil {
logger.Warnf(ctx, "failed to read task information when trying to construct Pod, err: %s", err.Error())
return nil, err
}
// Further processing using taskTemplate
}BuildResourceancient-wolf-19325
08/05/2024, 1:09 PM>>```func (p plugin) BuildResource(ctx context.Context, taskCtx pluginsCore.TaskExecutionContext) (client.Object, error) { taskTemplate, err := taskCtx.TaskReader().Read(ctx) if err != nil { logger.Warnf(ctx, "failed to read task information when trying to construct Pod, err: %s", err.Error()) return nil, err } var podSpec *v1.PodSpec objectMeta := &metav1.ObjectMeta{ Annotations: make(map[string]string), Labels: make(map[string]string), } primaryContainerName := "" if taskTemplate.Type == SidecarTaskType && taskTemplate.TaskTypeVersion == 0 { sidecarJob := sidecarJob{} err := utils.UnmarshalStructToObj(taskTemplate.GetCustom(), &sidecarJob) if err != nil { return nil, pluginserrors.Errorf(pluginserrors.BadTaskSpecification, "invalid TaskSpecification [%v], Err: [%v]", taskTemplate.GetCustom(), err.Error()) } if sidecarJob.PodSpec == nil { return nil, pluginserrors.Errorf(pluginserrors.BadTaskSpecification, "invalid TaskSpecification, nil PodSpec [%v]", taskTemplate.GetCustom()) } podSpec = sidecarJob.PodSpec primaryContainerName = sidecarJob.PrimaryContainerName objectMeta.Annotations = utils.UnionMaps(objectMeta.Annotations, sidecarJob.Annotations) objectMeta.Labels = utils.UnionMaps(objectMeta.Labels, sidecarJob.Labels) } else if taskTemplate.Type == SidecarTaskType && taskTemplate.TaskTypeVersion == 1 { err := utils.UnmarshalStructToObj(taskTemplate.GetCustom(), &podSpec) if err != nil { return nil, pluginserrors.Errorf(pluginserrors.BadTaskSpecification, "Unable to unmarshal task custom [%v], Err: [%v]", taskTemplate.GetCustom(), err.Error()) } if len(taskTemplate.GetConfig()) == 0 { return nil, pluginserrors.Errorf(pluginserrors.BadTaskSpecification, "invalid TaskSpecification, config needs to be non-empty and include missing [%s] key", flytek8s.PrimaryContainerKey) } var ok bool if primaryContainerName, ok = taskTemplate.GetConfig()[flytek8s.PrimaryContainerKey]; !ok { return nil, pluginserrors.Errorf(pluginserrors.BadTaskSpecification, "invalid TaskSpecification, config missing [%s] key in [%v]", flytek8s.PrimaryContainerKey, taskTemplate.GetConfig()) } } // Further processing to build the Pod resource } ```
ancient-wolf-19325
08/05/2024, 1:09 PM>>Summary - Interface:
TaskReaderReadBuildResourceTaskReader2 Views