(id string)
| 126 | } |
| 127 | |
| 128 | func (is *infoStore) setAborted(id string) { |
| 129 | jInfo, err := is.getJob(id) |
| 130 | debug.AssertNoErr(err) |
| 131 | jInfo.Aborted.Store(true) |
| 132 | // NOTE: Don't set `FinishedTime` yet as we are not fully done. |
| 133 | // The job now can be removed but there's no guarantee |
| 134 | // that all tasks have been stopped and all resources were freed. |
| 135 | } |
| 136 | |
| 137 | func (is *infoStore) delJob(id string) { |
| 138 | delete(is.jobInfo, id) |
no test coverage detected