(job *rivertype.JobRow)
| 741 | } |
| 742 | |
| 743 | func (p *producer) removeActiveJob(job *rivertype.JobRow) { |
| 744 | executor := p.activeJobs[job.ID] |
| 745 | delete(p.activeJobs, job.ID) |
| 746 | if executor == nil || executor.TryCloseSlot() { |
| 747 | p.numJobsActive.Add(-1) |
| 748 | } |
| 749 | p.numJobsRan.Add(1) |
| 750 | p.state.JobFinish(job) |
| 751 | } |
| 752 | |
| 753 | func (p *producer) handleWorkerStuck(ctx context.Context, executor *jobexecutor.JobExecutor, job *rivertype.JobRow) { |
| 754 | p.numJobsStuck.Add(1) |
no test coverage detected