(ctx context.Context)
| 152 | } |
| 153 | |
| 154 | func GetAllJobManagerStatus(ctx context.Context) ([]*wshrpc.JobManagerStatusUpdate, error) { |
| 155 | allJobs, err := wstore.DBGetAllObjsByType[*waveobj.Job](ctx, waveobj.OType_Job) |
| 156 | if err != nil { |
| 157 | return nil, fmt.Errorf("failed to get jobs: %w", err) |
| 158 | } |
| 159 | |
| 160 | var statuses []*wshrpc.JobManagerStatusUpdate |
| 161 | for _, job := range allJobs { |
| 162 | statuses = append(statuses, &wshrpc.JobManagerStatusUpdate{ |
| 163 | JobId: job.OID, |
| 164 | JobManagerStatus: job.JobManagerStatus, |
| 165 | }) |
| 166 | } |
| 167 | |
| 168 | return statuses, nil |
| 169 | } |
| 170 | |
| 171 | func GetBlockJobStatus(ctx context.Context, blockId string) (*wshrpc.BlockJobStatusData, error) { |
| 172 | block, err := wstore.DBGet[*waveobj.Block](ctx, blockId) |
nothing calls this directly
no test coverage detected