(ctx context.Context, skillID *int64)
| 586 | } |
| 587 | |
| 588 | func (s *SkillLibraryService) runScanWorker(ctx context.Context, skillID *int64) error { |
| 589 | if model.DB == nil { |
| 590 | return nil |
| 591 | } |
| 592 | job, err := s.claimPendingScanJob(skillID) |
| 593 | if err != nil { |
| 594 | return err |
| 595 | } |
| 596 | if job == nil { |
| 597 | return nil |
| 598 | } |
| 599 | return s.executeScanJob(ctx, job) |
| 600 | } |
| 601 | |
| 602 | func (s *SkillLibraryService) runImportWorker(ctx context.Context, jobID int64) error { |
| 603 | if model.DB == nil || jobID <= 0 { |
nothing calls this directly
no test coverage detected