Skip to content

Commit

Permalink
remove stale code
Browse files Browse the repository at this point in the history
  • Loading branch information
stevenlanders committed Dec 13, 2023
1 parent 7f7e772 commit 16a9e50
Showing 1 changed file with 0 additions and 26 deletions.
26 changes: 0 additions & 26 deletions tasks/scheduler.go
Original file line number Diff line number Diff line change
Expand Up @@ -440,32 +440,6 @@ func (s *scheduler) prepareTask(task *deliverTxTask) {
task.Ctx = ctx
}

// executeTask executes a single task
func (s *scheduler) executeTask3(task *deliverTxTask) {
s.prepareTask(task)
dCtx, dSpan := s.traceSpan(task.Ctx, "SchedulerDeliverTx", task)
defer dSpan.End()
task.Ctx = dCtx

resp := s.deliverTx(task.Ctx, task.Request)

close(task.AbortCh)

if abt, ok := <-task.AbortCh; ok {
task.Status = statusAborted
task.Abort = &abt
return
}

// write from version store to multiversion stores
for _, v := range task.VersionStores {
v.WriteToMultiVersionStore()
}

task.Status = statusExecuted
task.Response = &resp
}

func (s *scheduler) executeTask(task *deliverTxTask) {
dCtx, dSpan := s.traceSpan(task.Ctx, "SchedulerExecuteTask", task)
defer dSpan.End()
Expand Down

0 comments on commit 16a9e50

Please sign in to comment.