Flyte enables production-grade orchestration for machine learning workflows and data processing created to accelerate local workflows to production.

Flyte

image.png

Hello again. Trying to understand pod plugin code, so to take it as reference to develop other custom backend plugins for our need on k8s.

Need some help in understanding links between functions calls and their definitions.
currently, taskCtx.TaskReader().Read(ctx) is referring to an interface. But where is the implementation for this interface. I can only see it is called in BuildResource method. Could some can explain us code?

you’re referring to the <https://github.com/flyteorg/flyte/blob/0a441a97c990024c0f6e07a39939fb3aa1f4b7f0/flyteplugins/go/tasks/pluginmachinery/core/exec_context.go#L21|TaskReader> interface?

i think the implementation that you want is the `lazyUploadingTaskReader`, <https://github.com/flyteorg/flyte/blob/0a441a97c990024c0f6e07a39939fb3aa1f4b7f0/flyteplugins/go/tasks/pluginmachinery/ioutils/task_reader.go#L26|here>

the plugin machinery is a bit much, which is why we took the path of developing the flyte agents plugin framework.

some of the interfaces you see in flyteplugins are implemented in propeller.

if you’re looking to write a plugin that creates a k8s object though, look to the <https://github.com/flyteorg/flyte/tree/master/flyteplugins/go/tasks/plugins/k8s|existing> plugins for inspiration

Hello <@UNR3C6Y4T>, yes I was referring to existing pod plugin code.
there itself I got doubt related to taskreader interface.