func()

in loader/stream_loader.go [338:343]

• 6 lines of code
• 1 McCabe index (conditional complexity)

func (s *StreamLoad) handleSendError(workerIndex int, taskIndex int) {
	s.report.Lock.Lock()
	s.report.FinishedWorkers += 1
	s.report.FailedWorkers[workerIndex] = taskIndex
	s.report.Lock.Unlock()
}