Kubeflow TensorFlow
flytekitplugins-kftensorflow
This plugin uses the Kubeflow TensorFlow Operator and provides an extremely simplified interface for executing distributed training using various TensorFlow backends.
pip install flytekitplugins-kftensorflowQuick Start(example, may need adjustment)
See full examplespip install flytekitplugins-kftensorflow
from flytekit import task, workflow
from flytekitplugins.kftensorflow import PS, Chief, CleanPodPolicy, Evaluator
@task(task_config=TfJob(...))
def my_task() -> None:
...
@workflow
def my_workflow() -> None:
my_task()Available Imports (8)
Configuration type for Kubeflow TensorFlow.
extends dataclass — configuration or data structure for plugin setup
from flytekitplugins.kftensorflow import PS
Configuration type for Kubeflow TensorFlow.
extends dataclass — configuration or data structure for plugin setup
from flytekitplugins.kftensorflow import Chief
CleanPodPolicy describes how to deal with pods when the job is finished.
extends Enum — enumeration of predefined options
from flytekitplugins.kftensorflow import CleanPodPolicy
Configuration type for Kubeflow TensorFlow.
extends dataclass — configuration or data structure for plugin setup
from flytekitplugins.kftensorflow import Evaluator
RestartPolicy describes how the replicas should be restarted.
extends Enum — enumeration of predefined options
from flytekitplugins.kftensorflow import RestartPolicy
RunPolicy describes a set of policies to apply to the execution of a Kubeflow job.
extends dataclass — configuration or data structure for plugin setup
from flytekitplugins.kftensorflow import RunPolicy
Configuration for an executable [`TensorFlow Job`](https://github.com/kubeflow/tf-operator).
extends dataclass — configuration or data structure for plugin setup
from flytekitplugins.kftensorflow import TfJob
Configuration type for Kubeflow TensorFlow.
extends dataclass — configuration or data structure for plugin setup
from flytekitplugins.kftensorflow import Worker
Related Plugins
Kubeflow PyTorch
This plugin uses the Kubeflow PyTorch Operator and provides an extremely simplified interface for executing distributed training using various PyTorch backends.
Kubeflow MPI
This plugin uses the Kubeflow MPI Operator and provides an extremely simplified interface for executing distributed training.
Dask
Flyte can execute dask jobs natively on a Kubernetes Cluster, which manages the virtual dask cluster's lifecycle
Dask
Flyte can execute dask jobs natively on a Kubernetes Cluster, which manages the virtual dask cluster's lifecycle