Task pause schedule (CE part)

api/task_sched.go

@@ -0,0 +1,14 @@
+// Copyright (c) HashiCorp, Inc.
+// SPDX-License-Identifier: MPL-2.0
+
+package api
+
+type TaskSchedule struct {
+	Cron *TaskScheduleCron `hcl:"cron,block"`
+}
+
+type TaskScheduleCron struct {
+	Start    string `hcl:"start,optional"`
+	Stop     string `hcl:"stop,optional"`
+	Timezone string `hcl:"timezone,optional"`
+}

api/tasks.go

@@ -801,6 +801,8 @@ type Task struct {
 	Identities []*WorkloadIdentity `hcl:"identity,block"`
 
 	Actions []*Action `hcl:"action,block"`
+
+	Schedule *TaskSchedule `hcl:"schedule,block"`
 }
 
 func (t *Task) Canonicalize(tg *TaskGroup, job *Job) {

command/agent/job_endpoint.go

@@ -1425,6 +1425,11 @@ func ApiTaskToStructsTask(job *structs.Job, group *structs.TaskGroup,
 		act := ApiActionToStructsAction(job, action)
 		structsTask.Actions = append(structsTask.Actions, act)
 	}
+
+	if apiTask.Schedule != nil {
+		sched := apiScheduleToStructsSchedule(apiTask.Schedule)
+		structsTask.Schedule = sched
+	}
 }
 
 // apiWaitConfigToStructsWaitConfig is a copy and type conversion between the API
@@ -1475,6 +1480,21 @@ func ApiActionToStructsAction(job *structs.Job, action *api.Action) *structs.Act
 	}
 }
 
+func apiScheduleToStructsSchedule(s *api.TaskSchedule) *structs.TaskSchedule {
+	if s.Cron == nil {
+		// Since cron is the only field, drop the whole schedule block if its empty
+		return nil
+	}
+
+	return &structs.TaskSchedule{
+		Cron: &structs.TaskScheduleCron{
+			Start:    s.Cron.Start,
+			Stop:     s.Cron.Stop,
+			Timezone: s.Cron.Timezone,
+		},
+	}
+}
+
 func ApiResourcesToStructs(in *api.Resources) *structs.Resources {
 	if in == nil {
 		return nil

nomad/job_endpoint.go

@@ -88,6 +88,7 @@ func NewJobEndpoints(s *Server, ctx *RPCContext) *Job {
 			&jobValidate{srv: s},
 			&memoryOversubscriptionValidate{srv: s},
 			jobNumaHook{},
+			jobSchedHook{},
 		},
 	}
 }

nomad/job_endpoint_hook_sched.go

@@ -0,0 +1,13 @@
+// Copyright (c) HashiCorp, Inc.
+// SPDX-License-Identifier: BUSL-1.1
+
+package nomad
+
+// jobSchedHook implements a job Validating admission controller.
+//
+// The implementation of Validate are in the _ce/_ent files.
+type jobSchedHook struct{}
+
+func (jobSchedHook) Name() string {
+	return "schedule"
+}

nomad/job_endpoint_hook_sched_ce.go

@@ -0,0 +1,23 @@
+// Copyright (c) HashiCorp, Inc.
+// SPDX-License-Identifier: BUSL-1.1
+
+//go:build !ent
+
+package nomad
+
+import (
+	"errors"
+
+	"github.com/hashicorp/nomad/nomad/structs"
+)
+
+func (jobSchedHook) Validate(job *structs.Job) ([]error, error) {
+	for _, tg := range job.TaskGroups {
+		for _, task := range tg.Tasks {
+			if task.Schedule != nil {
+				return nil, errors.New("task schedules requires Nomad Enterprise")
+			}
+		}
+	}
+	return nil, nil
+}

nomad/structs/structs.go

@@ -7700,6 +7700,9 @@ type Task struct {
 
 	// Alloc-exec-like runnable commands
 	Actions []*Action
+
+	// Schedule for pausing tasks. Enterprise only.
+	Schedule *TaskSchedule
 }
 
 func (t *Task) UsesCores() bool {

nomad/structs/task_sched.go

@@ -0,0 +1,14 @@
+// Copyright (c) HashiCorp, Inc.
+// SPDX-License-Identifier: BUSL-1.1
+
+package structs
+
+type TaskSchedule struct {
+	Cron *TaskScheduleCron
+}
+
+type TaskScheduleCron struct {
+	Start    string
+	Stop     string
+	Timezone string
+}