Function isJobManagerRunning

pkg/jobcontroller/jobcontroller.go:139–141 · view source on GitHub ↗

(job *waveobj.Job)

Source from the content-addressed store, hash-verified

137	}
138
139	func isJobManagerRunning(job *waveobj.Job) bool {
140	return job.JobManagerStatus == JobManagerStatus_Running
141	}
142
143	func GetJobManagerStatus(ctx context.Context, jobId string) (string, error) {
144	job, err := wstore.DBGet[*waveobj.Job](ctx, jobId)

handleRouteEventFunction · 0.85

onConnectionUpFunction · 0.85

ReconnectJobsForConnFunction · 0.85

no outgoing calls

no test coverage detected