()
| 676 | } |
| 677 | |
| 678 | func (p *producer) executorShutdownLoop() { |
| 679 | // No more jobs will be fetched or executed. However, we must wait for all |
| 680 | // in-progress jobs to complete. |
| 681 | for len(p.activeJobs) != 0 { |
| 682 | result := <-p.jobResultCh |
| 683 | p.removeActiveJob(result) |
| 684 | } |
| 685 | } |
| 686 | |
| 687 | func (p *producer) finalizeShutdown(ctx context.Context) { |
| 688 | p.Logger.DebugContext(ctx, p.Name+": Finalizing shutdown") |
no test coverage detected