(ctx context.Context, jobId string)
| 1399 | } |
| 1400 | |
| 1401 | func DeleteJob(ctx context.Context, jobId string) error { |
| 1402 | SetJobConnStatus(jobId, JobConnStatus_Disconnected) |
| 1403 | jobTerminationMessageWritten.Delete(jobId) |
| 1404 | err := filestore.WFS.DeleteZone(ctx, jobId) |
| 1405 | if err != nil { |
| 1406 | log.Printf("[job:%s] warning: error deleting WaveFS zone: %v", jobId, err) |
| 1407 | } |
| 1408 | return wstore.DBDelete(ctx, waveobj.OType_Job, jobId) |
| 1409 | } |
| 1410 | |
| 1411 | func AttachJobToBlock(ctx context.Context, jobId string, blockId string) error { |
| 1412 | err := wstore.WithTx(ctx, func(tx *wstore.TxWrap) error { |
no test coverage detected