Kubernetes Pod

flytekitplugins-pod

FlytekitCloud & Infrastructurekubernetesk8spodcontainer

By default, Flyte tasks decorated with @task are essentially single functions that are loaded in one container. But often, there is a need to run a job with more than one container.

Install

pip install flytekitplugins-pod

Quick Start(example, may need adjustment)

See full examples

pip install flytekitplugins-pod

from flytekit import task, workflow
from flytekitplugins.pod import Pod

config = Pod(...)

@task
def my_task() -> None:
    ...

@workflow
def my_workflow() -> None:
    my_task()

Available Imports (1)

configPod

Pod is a platform-wide configuration that uses pod templates.

extends dataclass — configuration or data structure for plugin setup

from flytekitplugins.pod import Pod

Dependencies

kubernetes

Related Plugins

Kubernetes Stateful

Cloud & Infrastructure

This plugin provides support for Kubernetes StatefulSet and Service integration, enabling seamless provisioning and coordination with any Kubernetes services or Flyte tasks. It is especially suited for deep learning use cases at scale, where distributed and parallelized data loading and caching across nodes are required.

AWS Athena

Cloud & Infrastructure

Flyte backend can be connected with Athena. Once enabled, it allows you to query AWS Athena service (Presto + ANSI SQL Support) and retrieve typed schema (optionally).