> This page is for version 26.07 · v1.3.0.
> For other versions, use one of these documentation indexes:
> - Latest · v1.4.0 (26.09) (default): https://docs.nvidia.com/nemo/curator/latest/llms.txt
> - Main · preview: https://docs.nvidia.com/nemo/curator/main/llms.txt
> - 26.09 · v1.4.0: https://docs.nvidia.com/nemo/curator/v26.09/llms.txt
> - 26.07 · v1.3.0: https://docs.nvidia.com/nemo/curator/v26.07/llms.txt
> - 26.04 · v1.2.0: https://docs.nvidia.com/nemo/curator/v26.04/llms.txt
> - 26.02 · v1.1.0: https://docs.nvidia.com/nemo/curator/v26.02/llms.txt
> - 25.09 · v1.0.0: https://docs.nvidia.com/nemo/curator/v25.09/llms.txt

> For clean Markdown of any page, append .md to the page URL.
> For a complete documentation index, see https://docs.nvidia.com/nemo/curator/llms.txt.
> For AI client integration (Claude Code, Cursor, etc.), connect to the MCP server at https://docs.nvidia.com/nemo/curator/_mcp/server.

# nemo_curator.backends.xenna

## Submodules

* **[`nemo_curator.backends.xenna.adapter`](/nemo/curator/nemo-curator/nemo_curator/backends/xenna/adapter)**
* **[`nemo_curator.backends.xenna.executor`](/nemo/curator/nemo-curator/nemo_curator/backends/xenna/executor)**

## Package Contents

### Classes

| Name                                                                   | Description                                      |
| ---------------------------------------------------------------------- | ------------------------------------------------ |
| [`XennaExecutor`](#nemo_curator-backends-xenna-executor-XennaExecutor) | Executor that runs pipelines using Cosmos-Xenna. |

### API

```python
class nemo_curator.backends.xenna.XennaExecutor(
    config: dict[str, typing.Any] | None = None,
    ignore_head_node: bool = False
)
```

**Bases:** [BaseExecutor](/nemo/curator/nemo-curator/nemo_curator/backends/base#nemo_curator-backends-base-BaseExecutor)

Executor that runs pipelines using Cosmos-Xenna.
This executor provides integration between the nemo-curator pipeline framework
and the Cosmos-Xenna execution engine for distributed processing.

**`_default_pipeline_config`**

---

```python
nemo_curator.backends.xenna.XennaExecutor._get_pipeline_config(
    key: str
) -> typing.Any
```

Get configuration value with fallback to defaults.

```python
nemo_curator.backends.xenna.XennaExecutor.execute(
    stages: list[nemo_curator.stages.base.ProcessingStage],
    initial_tasks: list[nemo_curator.tasks.Task] | None = None
) -> list[nemo_curator.tasks.Task]
```

Execute the pipeline using Cosmos-Xenna.

**Parameters:**

**`stages`** `list[ProcessingStage]`

`list[` [`ProcessingStage`](/nemo/curator/nemo-curator/nemo_curator/stages/base#nemo_curator-stages-base-ProcessingStage) `]` — The stages to run

---

**`initial_tasks`** `list[Task]` — default: None

`list[` [`Task`](/nemo/curator/nemo-curator/nemo_curator/tasks/tasks#nemo_curator-tasks-tasks-Task) `]` — The initial tasks to run. Empty list of Task is used if not provided.

---

**Returns:** `list[` [`Task`](/nemo/curator/nemo-curator/nemo_curator/tasks/tasks#nemo_curator-tasks-tasks-Task) `]`

list\[Task]: List of output tasks from the pipeline