Skip to content

Commit

Permalink
Merge release v0.1.5
Browse files Browse the repository at this point in the history
Release v0.1.5
  • Loading branch information
bdevcich authored Jul 16, 2024
2 parents 27732c5 + e9c843a commit 0030f36
Show file tree
Hide file tree
Showing 9 changed files with 343 additions and 6 deletions.
8 changes: 8 additions & 0 deletions docs/guides/data-movement/readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -90,6 +90,14 @@ The `CreateRequest` API call that is used to create Data Movement with the Copy
options to allow a user to specify some options for that particular Data Movement. These settings
are on a per-request basis.

The Copy Offload API requires the `nnf-dm` daemon to be running on the compute node. This daemon may be configured to run full-time, or it may be left in a disabled state if the WLM is expected to run it only when a user requests it. See [Compute Daemons](../compute-daemons/readme.md) for the systemd service configuration of the daemon. See `RequiredDaemons` in [Directive Breakdown](../directive-breakdown/readme.md) for a description of how the user may request the daemon, in the case where the WLM will run it only on demand.

If the WLM is running the `nnf-dm` daemon only on demand, then the user can request that the daemon be running for their job by specifying `requires=copy-offload` in their `DW` directive. The following is an example:

```bash
#DW jobdw type=xfs capacity=1GB name=stg1 requires=copy-offload
```

See the [DataMovementCreateRequest API](copy-offload-api.html#datamovement.DataMovementCreateRequest)
definition for what can be configured.

Expand Down
181 changes: 181 additions & 0 deletions docs/guides/directive-breakdown/readme.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,181 @@
---
authors: Matt Richerson <[email protected]>
categories: provisioning
---

# Directive Breakdown

## Background

The `#DW` directives in a job script are not intended to be interpreted by the workload manager. The workload manager passes the `#DW` directives to the NNF software through the DWS `workflow` resource, and the NNF software determines what resources are needed to satisfy the directives. The NNF software communicates this information back to the workload manager through the DWS `DirectiveBreakdown` resource. This document describes how the WLM should interpret the information in the `DirectiveBreakdown`.

## DirectiveBreakdown Overview

The DWS `DirectiveBreakdown` contains all the information necessary to inform the WLM how to pick storage and compute nodes for a job. The `DirectiveBreakdown` resource is created by the NNF software during the `Proposal` phase of the DWS workflow. The `spec` section of the `DirectiveBreakdown` is filled in with the `#DW` directive by the NNF software, and the `status` section contains the information for the WLM. The WLM should wait until the `status.ready` field is true before interpreting the rest of the `status` fields.

The contents of the `DirectiveBreakdown` will look different depending on the file system type and options specified by the user. The `status` section contains enough information that the WLM may be able to figure out the underlying file system type requested by the user, but the WLM should not make any decisions based on the file system type. Instead, the WLM should make storage and compute allocation decisions based on the generic information provided in the `DirectiveBreakdown` since the storage and compute allocations needed to satisfy a `#DW` directive may differ based on options other than the file system type.

## Storage Nodes

The `status.storage` section of the `DirectiveBreakdown` describes how the storage allocations should be made and any constraints on the NNF nodes that can be picked. The `status.storage` section will exist only for `jobdw` and `create_persistent` directives. An example of the `status.storage` section is included below.

```yaml
...
spec:
directive: '#DW jobdw capacity=1GiB type=xfs name=example'
userID: 7900
status:
...
ready: true
storage:
allocationSets:
- allocationStrategy: AllocatePerCompute
constraints:
labels:
- dataworkflowservices.github.io/storage=Rabbit
label: xfs
minimumCapacity: 1073741824
lifetime: job
reference:
kind: Servers
name: example-0
namespace: default
...
```

* `status.storage.allocationSets` is a list of storage allocation sets that are needed for the job. An allocation set is a group of individual storage allocations that all have the same parameters and requirements. Depending on the storage type specified by the user, there may be more than one allocation set. Allocation sets should be handled independently.

* `status.storage.allocationSets.allocationStrategy` specifies how the allocations should be made.
* `AllocatePerCompute` - One allocation is needed per compute node in the job. The size of an individual allocation is specified in `status.storage.allocationSets.minimumCapacity`
* `AllocateAcrossServers` - One or more allocations are needed with an aggregate capacity of `status.storage.allocationSets.minimumCapacity`. This allocation strategy does not imply anything about how many allocations to make per NNF node or how many NNF nodes to use. The allocations on each NNF node should be the same size.
* `AllocateSingleServer` - One allocation is needed with a capacity of `status.storage.allocationSets.minimumCapacity`

* `status.storage.allocationSets.constraints` is a set of requirements for which NNF nodes can be picked. More information about the different constraint types is provided in the [Storage Constraints](readme.md#storage-constraints) section below.

* `status.storage.allocationSets.label` is an opaque string that the WLM uses when creating the spec.allocationSets entry in the DWS `Servers` resource.

* `status.storage.allocationSets.minimumCapacity` is the allocation capacity in bytes. The interpretation of this field depends on the value of `status.storage.allocationSets.allocationStrategy`

* `status.storage.lifetime` is used to specify how long the storage allocations will last.
* `job` - The allocation will last for the lifetime of the job
* `persistent` - The allocation will last for longer than the lifetime of the job

* `status.storage.reference` is an object reference to a DWS `Servers` resource where the WLM can specify allocations

### Storage Constraints

Constraints on an allocation set provide additional requirements for how the storage allocations should be made on NNF nodes.

* `labels` specifies a list of labels that must all be on a DWS `Storage` resource in order for an allocation to exist on that `Storage`.
```yaml
constraints:
labels:
- dataworkflowservices.github.io/storage=Rabbit
- mysite.org/pool=firmware_test
```
```yaml
apiVersion: dataworkflowservices.github.io/v1alpha2
kind: Storage
metadata:
labels:
dataworkflowservices.github.io/storage: Rabbit
mysite.org/pool: firmware_test
mysite.org/drive-speed: fast
name: rabbit-node-1
namespace: default
...
```

* `colocation` specifies how two or more allocations influence the location of each other. The colocation constraint has two fields, `type` and `key`. Currently, the only value for `type` is `exclusive`. `key` can be any value. This constraint means that the allocations from an allocation set with the colocation constraint can't be placed on an NNF node with another allocation whose allocation set has a colocation constraint with the same key. Allocations from allocation sets with colocation constraints with different keys or allocation sets without the colocation constraint are okay to put on the same NNF node.
```yaml
constraints:
colocation:
type: exclusive
key: lustre-mgt
```
* `count` this field specifies the number of allocations to make when `status.storage.allocationSets.allocationStrategy` is `AllocateAcrossServers`
```yaml
constraints:
count: 5
```

* `scale` is a unitless value from 1-10 that is meant to guide the WLM on how many allocations to make when `status.storage.allocationSets.allocationStrategy` is `AllocateAcrossServers`. The actual number of allocations is not meant to correspond to the value of scale. Rather, 1 would indicate the minimum number of allocations to reach `status.storage.allocationSets.minimumCapacity`, and 10 would be the maximum number of allocations that make sense given the `status.storage.allocationSets.minimumCapacity` and the compute node count. The NNF software does not interpret this value, and it is up to the WLM to define its meaning.
```yaml
constraints:
scale: 8
```

## Compute Nodes

The `status.compute` section of the `DirectiveBreakdown` describes how the WLM should pick compute nodes for a job. The `status.compute` section will exist only for `jobdw` and `persistentdw` directives. An example of the `status.compute` section is included below.

```yaml
...
spec:
directive: '#DW jobdw capacity=1TiB type=lustre name=example'
userID: 3450
status:
...
compute:
constraints:
location:
- access:
- priority: mandatory
type: network
- priority: bestEffort
type: physical
reference:
fieldPath: servers.spec.allocationSets[0]
kind: Servers
name: example-0
namespace: default
- access:
- priority: mandatory
type: network
reference:
fieldPath: servers.spec.allocationSets[1]
kind: Servers
name: example-0
namespace: default
...
```

The `status.compute.constraints` section lists any constraints on which compute nodes can be used. Currently the only constraint type is the `location` constraint. `status.compute.constraints.location` is a list of location constraints that all must be satisfied.

A location constraint consists of an `access` list and a `reference`.

* `status.compute.constraints.location.reference` is an object reference with a `fieldPath` that points to an allocation set in the `Servers` resource. If this is from a `#DW jobdw` directive, the `Servers` resource won't be filled in until the WLM picks storage nodes for the allocations.
* `status.compute.constraints.location.access` is a list that specifies what type of access the compute nodes need to have to the storage allocations in the allocation set. An allocation set may have multiple access types that are required
* `status.compute.constraints.location.access.type` specifies the connection type for the storage. This can be `network` or `physical`
* `status.compute.constraints.location.access.priority` specifies how necessary the connection type is. This can be `mandatory` or `bestEffort`

## RequiredDaemons

The `status.requiredDaemons` section of the `DirectiveBreakdown` tells the WLM about any driver-specific daemons it must enable for the job; it is assumed that the WLM knows about the driver-specific daemons and that if the users are specifying these then the WLM knows how to start them. The `status.requiredDaemons` section will exist only for `jobdw` and `persistentdw` directives. An example of the `status.requiredDaemons` section is included below.

```yaml
status:
...
requiredDaemons:
- copy-offload
...
```

The allowed list of required daemons that may be specified is defined in the [nnf-ruleset.yaml for DWS](https://github.com/NearNodeFlash/nnf-sos/blob/master/config/dws/nnf-ruleset.yaml), found in the `nnf-sos` repository. The `ruleDefs.key[requires]` statement is specified in two places in the ruleset, one for `jobdw` and the second for `persistentdw`. The ruleset allows a list of patterns to be specified, allowing one for each of the allowed daemons.

The `DW` directive will include a comma-separated list of daemons after the `requires` keyword. The following is an example:

```bash
#DW jobdw type=xfs capacity=1GB name=stg1 requires=copy-offload
```

The `DWDirectiveRule` resource currently active on the system can be viewed with:

```console
kubectl get -n dws-system dwdirectiverule nnf -o yaml
```

### Valid Daemons

Each site should define the list of daemons that are valid for that site and recognized by that site's WLM. The initial `nnf-ruleset.yaml` defines only one, called `copy-offload`. When a user specifies `copy-offload` in their `DW` directive, they are stating that their compute-node application will use the Copy Offload API Daemon described in the [Data Movement Configuration](../data-movement/readme.md).
2 changes: 2 additions & 0 deletions docs/guides/index.md
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@
* [Copy Offload API](data-movement/copy-offload-api.html)
* [Lustre External MGT](external-mgs/readme.md)
* [Global Lustre](global-lustre/readme.md)
* [Directive Breakdown](directive-breakdown/readme.md)

## NNF User Containers

Expand All @@ -23,3 +24,4 @@
## Node Management

* [Draining A Node](node-management/drain.md)
* [Debugging NVMe Namespaces](node-management/nvme-namespaces.md)
73 changes: 73 additions & 0 deletions docs/guides/node-management/nvme-namespaces.md
Original file line number Diff line number Diff line change
@@ -0,0 +1,73 @@
# Debugging NVMe Namespaces

## Total Space Available or Used

Find the total space available, and the total space used, on a Rabbit node using the Redfish API. One way to access the API is to use the `nnf-node-manager` pod on that node.

To view the space on node ee50, find its `nnf-node-manager` pod and then exec into it to query the Redfish API:

```console
[richerso@ee1:~]$ kubectl get pods -A -o wide | grep ee50 | grep node-manager
nnf-system nnf-node-manager-jhglm 1/1 Running 0 61m 10.85.71.11 ee50 <none> <none>
```

Then query the Redfish API to view the `AllocatedBytes` and `GuaranteedBytes`:

```console
[richerso@ee1:~]$ kubectl exec --stdin --tty -n nnf-system nnf-node-manager-jhglm -- curl -S localhost:50057/redfish/v1/StorageServices/NNF/CapacitySource | jq
{
"@odata.id": "/redfish/v1/StorageServices/NNF/CapacitySource",
"@odata.type": "#CapacitySource.v1_0_0.CapacitySource",
"Id": "0",
"Name": "Capacity Source",
"ProvidedCapacity": {
"Data": {
"AllocatedBytes": 128849888,
"ConsumedBytes": 128849888,
"GuaranteedBytes": 307132496928,
"ProvisionedBytes": 307261342816
},
"Metadata": {},
"Snapshot": {}
},
"ProvidedClassOfService": {},
"ProvidingDrives": {},
"ProvidingPools": {},
"ProvidingVolumes": {},
"Actions": {},
"ProvidingMemory": {},
"ProvidingMemoryChunks": {}
}
```

## Total Orphaned or Leaked Space

To determine the amount of orphaned space, look at the Rabbit node when there are no allocations on it. If there are no allocations then there should be no `NnfNodeBlockStorages` in the k8s namespace with the Rabbit's name:

```console
[richerso@ee1:~]$ kubectl get nnfnodeblockstorage -n ee50
No resources found in ee50 namespace.
```

To check that there are no orphaned namespaces, you can use the nvme command while logged into that Rabbit node:

```console
[root@ee50:~]# nvme list
Node SN Model Namespace Usage Format FW Rev
--------------------- -------------------- ---------------------------------------- --------- -------------------------- ---------------- --------
/dev/nvme0n1 S666NN0TB11877 SAMSUNG MZ1L21T9HCLS-00A07 1 8.57 GB / 1.92 TB 512 B + 0 B GDC7302Q
```

There should be no namespaces on the kioxia drives:

```console
[root@ee50:~]# nvme list | grep -i kioxia
[root@ee50:~]#
```

If there are namespaces listed, and there weren't any `NnfNodeBlockStorages` on the node, then they need to be deleted through the Rabbit software. The `NnfNodeECData` resource is a persistent data store for the allocations that should exist on the Rabbit. By deleting it, and then deleting the nnf-node-manager pod, it causes nnf-node-manager to delete the orphaned namespaces. This can take a few minutes after you actually delete the pod:

```console
kubectl delete nnfnodeecdata ec-data -n ee50
kubectl delete pod -n nnf-system nnf-node-manager-jhglm
```
26 changes: 24 additions & 2 deletions docs/guides/rbac-for-users/readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -133,9 +133,11 @@ DataWorkflowServices has already defined the role to be used with WLMs, named `d
kubectl get clusterrole dws-workload-manager
```

Create and apply a ClusterRoleBinding to associate the "flux" user with the `dws-workload-manager` ClusterRole:
If the "flux" user requires only the normal WLM permissions, then create and apply a ClusterRoleBinding to associate the "flux" user with the `dws-workload-manager` ClusterRole.

ClusterRoleBinding
The `dws-workload-manager role is defined in [workload_manager_role.yaml](https://github.com/DataWorkflowServices/dws/blob/master/config/rbac/workload_manager_role.yaml).

ClusterRoleBinding for WLM permissions only:
```yaml
apiVersion: rbac.authorization.k8s.io/v1
kind: ClusterRoleBinding
Expand All @@ -151,4 +153,24 @@ roleRef:
apiGroup: rbac.authorization.k8s.io
```

If the "flux" user requires the normal WLM permissions as well as some of the NNF permissions, perhaps to collect some NNF resources for debugging, then create and apply a ClusterRoleBinding to associate the "flux" user with the `nnf-workload-manager` ClusterRole.

The `nnf-workload-manager` role is defined in [workload_manager_nnf_role.yaml](https://github.com/NearNodeFlash/nnf-sos/blob/master/config/rbac/workload_manager_nnf_role.yaml).

ClusterRoleBinding for WLM and NNF permissions:
```yaml
apiVersion: rbac.authorization.k8s.io/v1
kind: ClusterRoleBinding
metadata:
name: flux
subjects:
- kind: User
name: flux
apiGroup: rbac.authorization.k8s.io
roleRef:
kind: ClusterRole
name: nnf-workload-manager
apiGroup: rbac.authorization.k8s.io
```

The WLM should then use the kubeconfig file associated with this "flux" user to access the DataWorkflowServices API and the Rabbit system.
Loading

0 comments on commit 0030f36

Please sign in to comment.