()
| 567 | } |
| 568 | |
| 569 | func GetNumJobsConnected() int { |
| 570 | jobControllerLock.Lock() |
| 571 | defer jobControllerLock.Unlock() |
| 572 | count := 0 |
| 573 | for _, status := range jobConnStates { |
| 574 | if status == JobConnStatus_Connected { |
| 575 | count++ |
| 576 | } |
| 577 | } |
| 578 | return count |
| 579 | } |
| 580 | |
| 581 | func CheckJobConnected(ctx context.Context, jobId string) (*waveobj.Job, error) { |
| 582 | job, err := wstore.DBMustGet[*waveobj.Job](ctx, jobId) |
no outgoing calls
no test coverage detected