(ctx context.Context, jobId string)
| 141 | } |
| 142 | |
| 143 | func GetJobManagerStatus(ctx context.Context, jobId string) (string, error) { |
| 144 | job, err := wstore.DBGet[*waveobj.Job](ctx, jobId) |
| 145 | if err != nil { |
| 146 | return "", fmt.Errorf("failed to get job: %w", err) |
| 147 | } |
| 148 | if job == nil { |
| 149 | return JobManagerStatus_Done, nil |
| 150 | } |
| 151 | return job.JobManagerStatus, nil |
| 152 | } |
| 153 | |
| 154 | func GetAllJobManagerStatus(ctx context.Context) ([]*wshrpc.JobManagerStatusUpdate, error) { |
| 155 | allJobs, err := wstore.DBGetAllObjsByType[*waveobj.Job](ctx, waveobj.OType_Job) |
no test coverage detected