From 5b74405f91aaac728643d15ea88f9781a479694b Mon Sep 17 00:00:00 2001 From: James Rasell Date: Tue, 6 Feb 2024 14:19:30 +0000 Subject: [PATCH] allocrunner: mark tasks as running and remove unused func. --- allocrunnersim/allocrunnersim.go | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/allocrunnersim/allocrunnersim.go b/allocrunnersim/allocrunnersim.go index 2ab7ca5..6b86eae 100644 --- a/allocrunnersim/allocrunnersim.go +++ b/allocrunnersim/allocrunnersim.go @@ -62,6 +62,7 @@ func (ar *simulatedAllocRunner) Run() { for _, task := range ar.taskNamesLocked() { ar.allocState.TaskStates[task] = structs.NewTaskState() ar.allocState.TaskStates[task].StartedAt = time.Now() + ar.allocState.TaskStates[task].State = structs.TaskStateRunning } ar.appendTaskEventForLocked(structs.TaskSetup) @@ -164,9 +165,6 @@ func (ar *simulatedAllocRunner) AllocState() *state.State { func (ar *simulatedAllocRunner) PersistState() error { return nil } func (ar *simulatedAllocRunner) AcknowledgeState(*state.State) {} -func (ar *simulatedAllocRunner) LastAcknowledgedStateIsCurrent(*structs.Allocation) bool { - return false -} func (ar *simulatedAllocRunner) SetClientStatus(status string) { ar.allocLock.Lock()