# flyte.clustered

## Directory

### Classes

| Class | Description |
|-|-|
| [`ClusterFailurePolicy`](https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/clusterfailurepolicy/page.md) | Failure and restart policy for the JobSet as a whole. |
| [`ClusteredTaskEnvironment`](https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/clusteredtaskenvironment/page.md) | A TaskEnvironment that emits a Kubernetes JobSet for distributed multi-node training. |
| [`ClusteredTaskTemplate`](https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/clusteredtasktemplate/page.md) | Task template for ``ClusteredTaskEnvironment``. |
| [`TorchRun`](https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/torchrun/page.md) | TorchRun launcher configuration for a ClusteredTaskEnvironment. |

## Subpages

- [ClusteredTaskEnvironment](https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/clusteredtaskenvironment/page.md)
  - Parameters
  - Properties
  - Methods
  - add_dependency()
  - clone_with()
  - from_task()
  - task()
  - to_custom_dict()
- [ClusteredTaskTemplate](https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/clusteredtasktemplate/page.md)
  - Parameters
  - Properties
  - Methods
  - aio()
  - config()
  - container_args()
  - custom_config()
  - data_loading_config()
  - execute()
  - forward()
  - override()
  - post()
  - pre()
  - sql()
- [ClusterFailurePolicy](https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/clusterfailurepolicy/page.md)
  - Parameters
- [TorchRun](https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/torchrun/page.md)
  - Parameters

---
**Source**: https://github.com/unionai/unionai-docs/blob/main/content/api-reference/flyte-sdk/packages/flyte.clustered/_index.md
**HTML**: https://www.union.ai/docs/v2/union/api-reference/flyte-sdk/packages/flyte.clustered/