Add support for K8sPod app payload in app_client.go

[pingsutw]

Summary

In app/internal/k8s/app_client.go, the Spec_Pod case is currently a stub that returns an error:

case *flyteapp.Spec_Pod:
    // K8sPod payloads are not yet supported — the pod spec serialization
    // from flyteplugins is needed for a complete implementation.
    return corev1.PodSpec{}, fmt.Errorf("K8sPod app payload is not yet supported")

What needs to be done

Implement the Spec_Pod case so that a K8sPod app payload is fully deserialized into a corev1.PodSpec. This requires:

1. Leveraging the pod spec serialization from flyteplugins (or an equivalent utility) to convert the flyteapp.Spec_Pod proto payload into a corev1.PodSpec.
2. Handling any container overrides, resource requirements, environment variables, and port mappings that may be present in the pod spec.
3. Adding unit tests covering the new code path.

Why this matters

Without this support, workflows that define tasks as K8sPod payloads cannot be scheduled via the app client, limiting the expressiveness available to Flyte v2 users.

Related

• app/internal/k8s/app_client.go — buildPodSpec function, Spec_Pod case

[runllm]

Currently, there is no implementation in the provided data sources for deserializing a flyteapp.Spec_Pod proto payload into a corev1.PodSpec in app_client.go. The data sources confirm that pod spec serialization and deserialization utilities exist in Flyte's backend, particularly in the flyteplugins machinery, but there is no direct reference or example for handling Spec_Pod payloads in the app client or for converting the proto to a Kubernetes PodSpec in Go code. The need for such a utility is acknowledged in the code comments, but the actual implementation is not present or documented in the data sources.

If you would like more detail on how Flyte handles pod spec serialization/deserialization elsewhere (e.g., in plugin machinery or task execution), or on how to approach implementing this, please let me know.

Sources:

• flyteplugins/go/tasks/pluginmachinery/flytek8s/pod_helper.go

---

This is an AI-generated response and your feedback is appreciated! Please leave a 👍 if this is helpful and 👎 if it is not.

Mention @RunLLM to ask follow-up questions. See runllm.com for more!