diff --git a/nomad/structs/volumes.go b/nomad/structs/volumes.go index f474fe1d28e..98149b8ce4c 100644 --- a/nomad/structs/volumes.go +++ b/nomad/structs/volumes.go @@ -174,7 +174,6 @@ func (v *VolumeRequest) Validate(jobType string, taskGroupCount, canaries int) e case VolumeTypeHost: if v.MountOptions != nil { - // TODO(1.10.0): support mount options for dynamic host volumes addErr("host volumes cannot have mount options") } diff --git a/scheduler/feasible.go b/scheduler/feasible.go index fa1800b2ae0..41ab48e81c2 100644 --- a/scheduler/feasible.go +++ b/scheduler/feasible.go @@ -206,10 +206,11 @@ func (h *HostVolumeChecker) hasVolumes(n *structs.Node) bool { if volCfg.ID != "" { // dynamic host volume vol, err := h.ctx.State().HostVolumeByID(nil, h.namespace, volCfg.ID, false) if err != nil || vol == nil { - // node fingerprint has a dynamic volume that's no longer in the - // state store; this is only possible if the batched fingerprint - // update from a delete RPC is written before the delete RPC's - // raft entry completes + // the dynamic host volume in the node fingerprint does not + // belong to the namespace we need. or the volume is no longer + // in the state store because the batched fingerprint update + // from a delete RPC is written before the delete RPC's raft + // entry completes return false } if !h.hostVolumeIsAvailable(vol,