(run Run)
| 1650 | } |
| 1651 | |
| 1652 | func requeuedTestRun(run Run) Run { |
| 1653 | run.Status = TaskRunStatusQueued |
| 1654 | run.ClaimedBy = nil |
| 1655 | run.SessionID = "" |
| 1656 | run.ClaimToken = "" |
| 1657 | run.ClaimTokenHash = "" |
| 1658 | run.LeaseUntil = time.Time{} |
| 1659 | run.HeartbeatAt = time.Time{} |
| 1660 | run.ClaimedAt = time.Time{} |
| 1661 | run.StartedAt = time.Time{} |
| 1662 | run.EndedAt = time.Time{} |
| 1663 | run.Error = "" |
| 1664 | run.Result = nil |
| 1665 | return run |
| 1666 | } |
| 1667 | |
| 1668 | func (s *inMemoryManagerStore) ReserveQueuedRun( |
| 1669 | _ context.Context, |
no outgoing calls
no test coverage detected